diff --git a/.idea/compiler.xml b/.idea/compiler.xml
index f006a55..5a76f28 100644
--- a/.idea/compiler.xml
+++ b/.idea/compiler.xml
@@ -6,6 +6,7 @@
+
diff --git a/.idea/jarRepositories.xml b/.idea/jarRepositories.xml
new file mode 100644
index 0000000..712ab9d
--- /dev/null
+++ b/.idea/jarRepositories.xml
@@ -0,0 +1,20 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/vcs.xml b/.idea/vcs.xml
new file mode 100644
index 0000000..35eb1dd
--- /dev/null
+++ b/.idea/vcs.xml
@@ -0,0 +1,6 @@
+
+
+
+
+
+
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index d97c43d..cfd5bb7 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,15 +4,39 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
- com.zipcoder.lab
- jdbcdao
+ org.example
+ intro-to-jdbc
1.0-SNAPSHOT
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.6.0
+
+ 1.8
+ 1.8
+
+
+
+
-
-
- junit
- junit
- 4.10
-
-
+
+
+
+ com.fasterxml.jackson.core
+ jackson-databind
+ 2.12.3
+
+
+ mysql
+ mysql-connector-java
+ 8.0.18
+
+
+ com.fasterxml.jackson.core
+ jackson-core
+ 2.13.0-rc1
+
+
\ No newline at end of file
diff --git a/src/main/java/MainApplication.java b/src/main/java/MainApplication.java
new file mode 100644
index 0000000..b126963
--- /dev/null
+++ b/src/main/java/MainApplication.java
@@ -0,0 +1,115 @@
+
+import com.mysql.cj.jdbc.Driver;
+import daos.CarsRepository;
+import models.Cars;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.StringJoiner;
+
+/**
+ * @author git-leon
+ * @version 1.0.0
+ * @date 8/2/21 9:49 AM
+ */
+public class MainApplication {
+
+ public static void main(String[] args) {
+ registerJDBCDriver();
+ Connection mysqlDbConnection = getConnection("mysql");
+ CarsRepository carsRepository = new CarsRepository(mysqlDbConnection);
+ executeStatement(mysqlDbConnection, "DROP DATABASE IF EXISTS Objects;");
+ executeStatement(mysqlDbConnection, "CREATE DATABASE IF NOT EXISTS Objects;");
+ executeStatement(mysqlDbConnection, "USE Objects;");
+ executeStatement(mysqlDbConnection, new StringBuilder()
+ .append("CREATE TABLE IF NOT EXISTS Objects.cars(")
+ .append("id int auto_increment primary key,")
+ .append("make text not null,")
+ .append("year int not null,")
+ .append("color text not null,")
+ .append("MPG int not null);")
+ .toString());
+
+ carsRepository.create(new Cars(1L, "Toyota", 1993, "red", 120 ));
+ carsRepository.create(new Cars(2L, "Ford", 1980, "black", 100));
+ carsRepository.create(new Cars(3L, "Jeep", 2000, "orange", 110));
+ carsRepository.create(new Cars(4L, "Volks Wagon", 2005, "silver", 140));
+ carsRepository.create(new Cars(5L, "Tesla", 2010, "silver", 150));
+ System.out.println(carsRepository.readAll());
+
+ }
+
+ static ResultSet executeQuery(Connection connection, String sqlQuery) {
+ try {
+ Statement statement = getScrollableStatement(connection);
+ return statement.executeQuery(sqlQuery);
+ } catch (SQLException e) {
+ throw new Error(e);
+ }
+ }
+
+ static void printResults(ResultSet resultSet) {
+ try {
+ for (int rowNumber = 0; resultSet.next(); rowNumber++) {
+ String firstColumnData = resultSet.getString(1);
+ String secondColumnData = resultSet.getString(2);
+ String thirdColumnData = resultSet.getString(3);
+ System.out.println(new StringJoiner("\n")
+ .add("Row number = " + rowNumber)
+ .add("First Column = " + firstColumnData)
+ .add("Second Column = " + secondColumnData)
+ .add("Third column = " + thirdColumnData));
+ }
+ } catch (SQLException e) {
+ throw new Error(e);
+ }
+ }
+
+ static void executeStatement(Connection connection, String sqlStatement) {
+ try {
+ Statement statement = getScrollableStatement(connection);
+ statement.execute(sqlStatement);
+ } catch (SQLException e) {
+ throw new Error(e);
+ }
+ }
+
+ static Statement getScrollableStatement(Connection connection) {
+ int resultSetType = ResultSet.TYPE_SCROLL_INSENSITIVE;
+ int resultSetConcurrency = ResultSet.CONCUR_READ_ONLY;
+ try { // scrollable statements can be iterated more than once without closing
+ return connection.createStatement(resultSetType, resultSetConcurrency);
+ } catch (SQLException e) {
+ throw new Error(e);
+ }
+ }
+
+ static Connection getConnection(String dbVendor) {
+ String username = "song";
+ String password = "songbass123";
+ String url = new StringBuilder()
+ .append("jdbc:")
+ .append(dbVendor)
+ .append("://127.0.0.1/")
+ .append("?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC")
+ .toString();
+ try {
+ return DriverManager.getConnection(url, username, password);
+ } catch (SQLException e) {
+ throw new Error(e);
+ }
+ }
+
+ static void registerJDBCDriver() {
+ // Attempt to register JDBC Driver
+ try {
+ DriverManager.registerDriver(Driver.class.newInstance());
+ } catch (InstantiationException | IllegalAccessException | SQLException e1) {
+ throw new RuntimeException(e1);
+ }
+ }
+
+}
diff --git a/src/main/java/daos/CarsRepository.java b/src/main/java/daos/CarsRepository.java
new file mode 100644
index 0000000..9157dad
--- /dev/null
+++ b/src/main/java/daos/CarsRepository.java
@@ -0,0 +1,103 @@
+package daos;
+
+import com.sun.deploy.net.MessageHeader;
+import models.Cars;
+
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author git-leon
+ * @version 1.0.0
+ * @date 8/4/21 3:05 PM
+ */
+public class CarsRepository implements Repo {
+ private Connection connection;
+
+ public CarsRepository(Connection connection) {
+ this.connection = connection;
+ }
+
+ @Override
+ public Connection getConnection() {
+ return connection;
+ }
+
+ public void create(Cars cars) {
+ executeStatement(String.format(new StringBuilder()
+ .append("INSERT INTO Objects.cars(")
+ .append("id, make, year, color, MPG) ")
+ .append("VALUES (%s, '%s', %s, '%s', %s);")
+ .toString(),
+ cars.getId(),
+ cars.getMake(),
+ cars.getYear(),
+ cars.getColor(),
+ cars.getMPG()));
+ }
+
+ public List readAll() {
+ ResultSet resultSet = executeQuery("SELECT * FROM Objects.cars;");
+ List list = new ArrayList<>();
+ try {
+ while (resultSet.next()) {
+ String id = resultSet.getString(1);
+ String make = resultSet.getString(2);
+ String year = resultSet.getString(3);
+ String color = resultSet.getString(4);
+ String MPG = resultSet.getString(5);
+ list.add(new Cars(
+ Long.parseLong(id),
+ make,
+ Integer.parseInt(year),
+ color,
+ Integer.parseInt(MPG)));
+ }
+ } catch (SQLException throwables) {
+ throw new RuntimeException(throwables);
+ }
+ return list;
+ }
+
+ public Cars read(Long id) {
+ return readAll()
+ .stream()
+ .filter(pokemon -> pokemon.getId().equals(id))
+ .findAny()
+ .get();
+ }
+
+ public void update(Long id, Cars newCar) {
+ executeStatement(String.format(new StringBuilder()
+ .append("Update cars Set make = '%s', ")
+ .append("year = '%s', ")
+ .append("color = '%s', ")
+ .append("MPG = '%s', ")
+ .toString(),
+
+ newCar.getMake(),
+ newCar.getYear(),
+ newCar.getColor(),
+ newCar.getMPG(),
+ id));
+
+
+ }
+
+ public void delete(Long id) {
+ executeStatement(String.format(new StringBuilder()
+ .append("DELETE FROM cars ")
+ .append("WHERE primaryID = %s; ")
+ .toString(),
+ id));
+
+ }
+
+ public void delete(Cars cars) {
+ delete(cars.getId());
+ }
+
+}
diff --git a/src/main/java/daos/DELETEME.txt b/src/main/java/daos/DELETEME.txt
deleted file mode 100644
index e69de29..0000000
diff --git a/src/main/java/daos/Repo.java b/src/main/java/daos/Repo.java
new file mode 100644
index 0000000..f1238f0
--- /dev/null
+++ b/src/main/java/daos/Repo.java
@@ -0,0 +1,43 @@
+package daos;
+
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+/**
+ * @author git-leon
+ * @version 1.0.0
+ * @date 8/4/21 3:15 PM
+ */
+public interface Repo {
+ default void executeStatement(String sqlStatement) {
+ try {
+ Statement statement = getScrollableStatement();
+ statement.execute(sqlStatement);
+ } catch (SQLException e) {
+ throw new Error(e);
+ }
+ }
+
+ default Statement getScrollableStatement() {
+ int resultSetType = ResultSet.TYPE_SCROLL_INSENSITIVE;
+ int resultSetConcurrency = ResultSet.CONCUR_READ_ONLY;
+ try { // scrollable statements can be iterated more than once without closing
+ return getConnection().createStatement(resultSetType, resultSetConcurrency);
+ } catch (SQLException e) {
+ throw new Error(e);
+ }
+ }
+
+ default ResultSet executeQuery(String sqlQuery) {
+ try {
+ Statement statement = getScrollableStatement();
+ return statement.executeQuery(sqlQuery);
+ } catch (SQLException e) {
+ throw new Error(e);
+ }
+ }
+
+ Connection getConnection();
+}
diff --git a/src/main/java/models/Cars.java b/src/main/java/models/Cars.java
new file mode 100644
index 0000000..5303d48
--- /dev/null
+++ b/src/main/java/models/Cars.java
@@ -0,0 +1,85 @@
+package models;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+/**
+ * @author git-leon
+ * @version 1.0.0
+ * @date 8/4/21 3:03 PM
+ */
+public class Cars {
+ private Long id;
+ private String make;
+ private Integer year;
+ private Integer MPG;
+ private String color;
+
+
+
+
+
+ public void setId(Long id) {
+ this.id = id;
+ }
+
+ public void setMake(String make) {
+ this.make = make;
+ }
+
+
+ public void setYear(Integer year) {
+ this.year = year;
+ }
+
+ public void setMPG(Integer MPG) {
+ this.MPG = MPG;
+ }
+
+ public Long getId() {
+ return id;
+ }
+
+ public String getMake() {
+ return make;
+ }
+
+ public Object getColor() {
+ return color;
+ }
+
+ public Integer getYear() {
+ return year;
+ }
+
+ public Integer getMPG() {
+ return MPG;
+ }
+
+ public Cars(Long id, String make, Integer year, String color, Integer MPG) {
+ this.id = id;
+ this.make = make;
+ this.year = year;
+ this.MPG = MPG;
+ this.color = color;
+ }
+
+ @Override
+ public String toString() {
+ try {
+ return new ObjectMapper().writeValueAsString(this);
+ } catch (JsonProcessingException e) {
+ return "Cars{" +
+ "id=" + id +
+ ", make='" + make + '\'' +
+ ", year='" + year +
+ ", color='" + color +
+ ", MPG=" + MPG +
+ '}';
+ }
+ }
+
+
+
+
+}
diff --git a/target/classes/MainApplication.class b/target/classes/MainApplication.class
new file mode 100644
index 0000000..193feec
Binary files /dev/null and b/target/classes/MainApplication.class differ
diff --git a/target/classes/daos/CarsRepository.class b/target/classes/daos/CarsRepository.class
new file mode 100644
index 0000000..8f950bf
Binary files /dev/null and b/target/classes/daos/CarsRepository.class differ
diff --git a/target/classes/daos/Repo.class b/target/classes/daos/Repo.class
new file mode 100644
index 0000000..97016f8
Binary files /dev/null and b/target/classes/daos/Repo.class differ
diff --git a/target/classes/models/Cars.class b/target/classes/models/Cars.class
new file mode 100644
index 0000000..4b609ef
Binary files /dev/null and b/target/classes/models/Cars.class differ