package insertImage;

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;


public class Mysql {
	static Connection conn = null;
	static Statement stmt = null;
	static ResultSet rs = null;
	static ResultSet rsImage=null;
	
    public static Connection connectToMySQL(String host, Integer port, String user, String password) {
    	try {
			conn = DriverManager.getConnection("jdbc:mysql://"+host+":"+port+"?",user, password);
	    	return conn;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();	
	    	return null;
		}
    }

    public static ResultSet executeQuery(String query) throws SQLException {
    	stmt = conn.createStatement();
        rs = stmt.executeQuery(query);
        return rs;
    }

    public static void insertImage(int id, File screenShotResized,File screenShot) throws SQLException, IOException {
 
    	BufferedInputStream screen = new BufferedInputStream(new FileInputStream(screenShot));
    	byte[] bytes = new byte[screen.available()];
    	
    	
    	BufferedInputStream screenResized = new BufferedInputStream(new FileInputStream(screenShotResized));
    	byte[] bytesMini = new byte[screenResized.available()];
    	
    	screen.read(bytes);
    	screenResized.read(bytesMini);

    	stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
    	
    	rsImage = stmt.executeQuery("select * from T_MODEL where idModel="+id);
    	rsImage.first();

    	rsImage.updateBytes("imageNormalModel", bytes);
    	rsImage.updateBytes("imageResizedModel", bytesMini);

    	rsImage.updateRow();

    	screen.close();
    	screenResized.close();
    }
    
    public static int executeUpdate(String query) throws SQLException {
    	stmt = conn.createStatement();
        int result = stmt.executeUpdate(query);
        return result;
    }
    
    public static void releaseAll() {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException sqlEx) {
                   System.out.println("SQLException: " + sqlEx.getMessage());
            }
            rs = null;
        }

        if (stmt != null) {
            try {
                stmt.close();
            } catch (SQLException sqlEx) {
                   System.out.println("SQLException: " + sqlEx.getMessage());
            }

            stmt = null;
        }

        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException sqlEx) {
                   // Ignore
            }

            conn = null;
        }
    }

	public static void newImage(int j) throws SQLException {
    	stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
    	rsImage = stmt.executeQuery("select * from T_MODEL where idModel="+j); 
    	rsImage.moveToInsertRow(); 
    	rsImage.updateInt("idModel",j);
    	rsImage.insertRow();
	}
    
}