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..9f3f6a3 100644 --- a/pom.xml +++ b/pom.xml @@ -4,15 +4,40 @@ 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 + + + junit + junit + 4.13.1 + test + + \ 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..472a2aa --- /dev/null +++ b/src/main/java/MainApplication.java @@ -0,0 +1,116 @@ + +import com.mysql.cj.jdbc.Driver; +import daos.VehicleRepo; +import models.Vehicle; + +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"); + VehicleRepo vehicleRepo = new VehicleRepo(mysqlDbConnection); + executeStatement(mysqlDbConnection, "DROP DATABASE IF EXISTS daolab;"); + executeStatement(mysqlDbConnection, "CREATE DATABASE IF NOT EXISTS daolab;"); + executeStatement(mysqlDbConnection, "USE daolab;"); + executeStatement(mysqlDbConnection, new StringBuilder() + .append("CREATE TABLE IF NOT EXISTS daolab.vehicle(") + .append("primaryId int auto_increment primary key,") + .append("make text not null,") + .append("model text not null,") + .append("color text not null,") + .append("vtype text not null,") + .append("mpg int not null);") + .toString()); + + Vehicle vehicle = new Vehicle(12L, "Nissan", "Maxima", "Charcoal", "Car", 40 ); + vehicleRepo.create(vehicle); + vehicleRepo.create(new Vehicle(13L, "Ford", "F150", "Blue", "Truck", 22 )); + vehicleRepo.update(12L, new Vehicle("Ford", "F150", "Blue", "Truck", 10 )); + vehicleRepo.delete(vehicle); + System.out.println(vehicleRepo.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 = "carl"; + String password = "carlpass"; + 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/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/daos/VehicleRepo.java b/src/main/java/daos/VehicleRepo.java new file mode 100644 index 0000000..4c88f0e --- /dev/null +++ b/src/main/java/daos/VehicleRepo.java @@ -0,0 +1,106 @@ +package daos; + +import models.Vehicle; + +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 VehicleRepo implements Repo { + private Connection connection; + + public VehicleRepo(Connection connection) { + this.connection = connection; + } + + @Override + public Connection getConnection() { + return connection; + } + + public void create(Vehicle vehicle) { + executeStatement(String.format(new StringBuilder() + .append("INSERT INTO daolab.vehicle(") + .append("primaryId, make, model, color, vtype, mpg) ") + .append("VALUES (%s, '%s', '%s', '%s', '%s', %s);") + .toString(), + vehicle.getId(), + vehicle.getMake(), + vehicle.getModel(), + vehicle.getColor(), + vehicle.getvType(), + vehicle.getMpg())); + } + + public List readAll() { + ResultSet resultSet = executeQuery("SELECT * FROM daolab.vehicle;"); + List list = new ArrayList<>(); + try { + while (resultSet.next()) { + String id = resultSet.getString(1); + String make = resultSet.getString(2); + String model = resultSet.getString(3); + String color = resultSet.getString(4); + String vtype = resultSet.getString(5); + String mpg = resultSet.getString(6); + list.add(new Vehicle( + Long.parseLong(id), + make, + model, + color, + vtype, + Integer.parseInt(mpg))); + } + } catch (SQLException throwables) { + throw new RuntimeException(throwables); + } + return list; + } + + public Vehicle read(Long primaryId) { + return readAll() + .stream() + .filter(vehicle -> vehicle.getId().equals(primaryId)) + .findAny() + .get(); + } + + public void update(Long id, Vehicle newVehicleData) { + executeStatement(String.format(new StringBuilder() + .append("UPDATE vehicle SET make= '%s',") + .append("model = '%s',") + .append("color = '%s',") + .append("vtype = '%s',") + .append("mpg = %s ") + .append("WHERE primaryId = %s;") + .toString(), + + newVehicleData.getMake(), + newVehicleData.getModel(), + newVehicleData.getColor(), + newVehicleData.getvType(), + newVehicleData.getMpg(), + id)); + } + + public void delete(Long id) { + executeStatement(String.format(new StringBuilder() + .append("DELETE FROM vehicle ") + .append("WHERE primaryId = %s;") + .toString(), + id + )); + } + + public void delete(Vehicle vehicle) { + delete(vehicle.getId()); + } + +} diff --git a/src/main/java/models/Vehicle.java b/src/main/java/models/Vehicle.java new file mode 100644 index 0000000..94bd52f --- /dev/null +++ b/src/main/java/models/Vehicle.java @@ -0,0 +1,103 @@ +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 Vehicle { + private Long id; + private String make; + private String model; + private String color; + private String vType; + private int mpg; + + public Vehicle() { + } + + public Vehicle(String make, String model, String color, String vType, int mpg) { + this.id = null; + this.make = make; + this.model = model; + this.color = color; + this.vType = vType; + this.mpg = mpg; + } + + public Vehicle(Long id, String make, String model, String color, String vType, int mpg) { + this.id = id; + this.make = make; + this.model = model; + this.color = color; + this.vType = vType; + this.mpg = mpg; + } + + public Long getId() { + return id; + } + + public void setId(Long id) { + this.id = id; + } + + public String getMake() { + return make; + } + + public void setMake(String make) { + this.make = make; + } + + public String getModel() { + return model; + } + + public void setModel(String model) { + this.model = model; + } + + public String getColor() { + return color; + } + + public void setColor(String color) { + this.color = color; + } + + public String getvType() { + return vType; + } + + public void setvType(String vType) { + this.vType = vType; + } + + public int getMpg() { + return mpg; + } + + public void setMpg(int mpg) { + this.mpg = mpg; + } + + @Override + public String toString() { + try { + return new ObjectMapper().writeValueAsString(this); + } catch (JsonProcessingException e) { + return "Pokemon{" + + "id=" + id + + ", Make='" + make + '\'' + + ", Model=" + model + + ", Color=" + color + + ", VehicleType= " + vType + + ", Mpg= " + mpg + + '}'; + } + } +} diff --git a/src/test/java/daos/DELETEME.txt b/src/test/java/daos/DELETEME.txt deleted file mode 100644 index e69de29..0000000 diff --git a/src/test/java/daos/VehicleRepo.java b/src/test/java/daos/VehicleRepo.java new file mode 100644 index 0000000..c1e316b --- /dev/null +++ b/src/test/java/daos/VehicleRepo.java @@ -0,0 +1,12 @@ +package daos; + +import com.mysql.cj.jdbc.Driver; +import org.junit.Test; + +import java.sql.*; +import java.util.StringJoiner; + + +public class VehicleRepo { + +} diff --git a/src/test/java/models/DELETEME.txt b/src/test/java/models/DELETEME.txt deleted file mode 100644 index e69de29..0000000 diff --git a/src/test/java/models/testVehicle.java b/src/test/java/models/testVehicle.java new file mode 100644 index 0000000..29efc28 --- /dev/null +++ b/src/test/java/models/testVehicle.java @@ -0,0 +1,53 @@ +package models; + + +import org.junit.Assert; +import org.junit.Test; + +public class testVehicle { + + @Test + public void testVehicleMake(){ + Vehicle vehicle = new Vehicle(20L, "Jenson", "Wagner", "Red", "Three Wheeler", 20); + String expected = "Jenson"; + String actual = vehicle.getMake(); + + Assert.assertEquals(expected, actual); + } + + @Test + public void testVehicleModel(){ + Vehicle vehicle = new Vehicle(20L, "Jenson", "Wagner", "Red", "Three Wheeler", 20); + String expected = "Wagner"; + String actual = vehicle.getModel(); + + Assert.assertEquals(expected, actual); + } + + @Test + public void testVehicleColor(){ + Vehicle vehicle = new Vehicle(20L, "Jenson", "Wagner", "Red", "Three Wheeler", 20); + String expected = "Red"; + String actual = vehicle.getColor(); + + Assert.assertEquals(expected, actual); + } + + @Test + public void testVehicleVType(){ + Vehicle vehicle = new Vehicle(20L, "Jenson", "Wagner", "Red", "Three Wheeler", 20); + String expected = "Three Wheeler"; + String actual = vehicle.getvType(); + + Assert.assertEquals(expected, actual); + } + + @Test + public void testVehicleMpg(){ + Vehicle vehicle = new Vehicle(20L, "Jenson", "Wagner", "Red", "Three Wheeler", 20); + Integer expected = 20; + Integer actual = vehicle.getMpg(); + + Assert.assertEquals(expected, actual); + } +} diff --git a/target/classes/MainApplication.class b/target/classes/MainApplication.class new file mode 100644 index 0000000..98800e5 Binary files /dev/null and b/target/classes/MainApplication.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/daos/VehicleRepo.class b/target/classes/daos/VehicleRepo.class new file mode 100644 index 0000000..02b94b4 Binary files /dev/null and b/target/classes/daos/VehicleRepo.class differ diff --git a/target/classes/models/Vehicle.class b/target/classes/models/Vehicle.class new file mode 100644 index 0000000..0f9bf0e Binary files /dev/null and b/target/classes/models/Vehicle.class differ diff --git a/target/test-classes/models/testVehicle.class b/target/test-classes/models/testVehicle.class new file mode 100644 index 0000000..acd0469 Binary files /dev/null and b/target/test-classes/models/testVehicle.class differ