Add files via upload

Author: dinocajic

DBConnection.java

@@ -0,0 +1,14 @@
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+
+class DBConnection {
+
+    private static final String USERNAME = "eci";
+    private static final String PASSWORD = "eci123";
+    private static final String CONN     = "jdbc:mysql://localhost:3306/eci";
+
+    static Connection getConnection() throws SQLException {
+        return DriverManager.getConnection(CONN, USERNAME, PASSWORD);
+    }
+}

Item.java

@@ -0,0 +1,85 @@
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.URL;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+class Item {
+
+    private static String[] match = {"/", "& ", "&", "-", ","};
+
+    static void getItems(ResultSet resultSet, String type) throws SQLException {
+
+        System.out.println("Displaying all items");
+
+        if ( type.equals("wheels") ) {
+            while( resultSet.next() )
+                System.out.println( downloadWheels( resultSet ) );
+
+        } else if ( type.equals("tires") ) {
+            while( resultSet.next() )
+                System.out.println( downloadTires( resultSet ) );
+        }
+
+        System.out.println("Finished");
+    }
+
+    private static String downloadWheels(ResultSet resultSet) throws SQLException {
+        String item_number = resultSet.getString( "item_number");
+        String brand       = resultSet.getString( "brand" );
+        String model       = resultSet.getString( "model" );
+        String finish      = resultSet.getString( "finish" );
+
+        brand  = sanitizeData( brand );
+        model  = sanitizeData( model );
+        finish = sanitizeData( finish );
+
+        String image_location = "http://website.com/version_2/img/wheels/" + brand + "/" + model + "_" + finish + ".jpg";
+
+        try(InputStream in = new URL( image_location ).openStream()){
+            Files.copy(in, Paths.get("D:/DB/FCWT/applications/eci-website-images/wheels/" + item_number + ".jpg"));
+        } catch (IOException e) {
+            //try with png
+            try(InputStream in = new URL( image_location.replace( ".jpg", ".png" ) ).openStream()) {
+                Files.copy(in, Paths.get("D:/DB/FCWT/applications/eci-website-images/wheels/" + item_number + ".jpg"));
+            } catch ( IOException ignored ) {}
+        }
+
+        return image_location;
+    }
+
+    private static String downloadTires(ResultSet resultSet) throws SQLException {
+        String item_number = resultSet.getString( "item_number");
+        String brand       = resultSet.getString( "brand" );
+        String model       = resultSet.getString( "model" );
+
+        brand  = sanitizeData( brand );
+        model  = sanitizeData( model );
+
+        String image_location = "http://website.com/version_2/img/tires/" + brand + "/" + model + ".jpg";
+
+        try(InputStream in = new URL( image_location ).openStream()){
+            Files.copy(in, Paths.get("D:/DB/FCWT/applications/eci-website-images/tires/" + item_number + ".jpg"));
+        } catch (IOException e) {
+            //try with png
+            try(InputStream in = new URL( image_location.replace( ".jpg", ".png" ) ).openStream()) {
+                Files.copy(in, Paths.get("D:/DB/FCWT/applications/eci-website-images/tires/" + item_number + ".jpg"));
+            } catch ( IOException ignored ) {}
+        }
+
+        return image_location;
+    }
+
+    private static String sanitizeData( String str ) {
+        str = str.toLowerCase();
+
+        for ( String replacement : match )
+            str = str.replace( replacement, "" );
+
+        str = str.replace(" ", "_");
+
+        return str;
+    }
+}

Main.java

@@ -0,0 +1,50 @@
+import java.sql.*;
+
+public class Main {
+
+    private static String type = "wheels"; // or tires
+
+    public static void main(String[] args) {
+
+        String sql_query = ( type.equals("wheels") ) ? getWheelQuery() : getTireQuery() ;
+
+        try (
+                Connection connection = DBConnection.getConnection();
+                Statement statement = connection.createStatement(
+                        ResultSet.TYPE_SCROLL_INSENSITIVE,
+                        ResultSet.CONCUR_READ_ONLY
+                );
+                ResultSet resultSet = statement.executeQuery( sql_query );
+        ){
+
+            Item.getItems( resultSet, type );
+
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+    }
+
+    private static String getWheelQuery() {
+        return "SELECT " +
+                "wheels.id as id, " +
+                "wheels.item_number as item_number, " +
+                "brand.brand_name as brand, " +
+                "model.model_name as model, " +
+                "wheel_finish.finish as finish " +
+                "FROM wheels " +
+                "JOIN brand ON wheels.brand = brand.id " +
+                "JOIN model ON wheels.model = model.id " +
+                "JOIN wheel_finish ON wheels.full_finish = wheel_finish.id WHERE wheels.active = 1";
+    }
+
+    private static String getTireQuery() {
+        return "SELECT " +
+                "tires.id as id, " +
+                "tires.item_number as item_number, " +
+                "brand.brand_name as brand, " +
+                "model.model_name as model " +
+                "FROM tires " +
+                "JOIN brand ON tires.brand = brand.id " +
+                "JOIN model ON tires.model = model.id WHERE tires.active = 1";
+    }
+}

pom.xml

@@ -0,0 +1,31 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>org.example</groupId>
+    <artifactId>eci-website-images</artifactId>
+    <version>1.0-SNAPSHOT</version>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>8</source>
+                    <target>8</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+    <dependencies>
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <version>8.0.19</version>
+        </dependency>
+    </dependencies>
+
+</project>