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;
    
	public Mysql() {
		
	}
	
    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) {
			e.printStackTrace();	
	    	return null;
		}
    }

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

    public static void insertImage(int id, File screenShotResized,File screenShot) throws SQLException, IOException {
    	ResultSet rsImage = null;
    	Statement stmt = null;
    	BufferedInputStream screen = null;
    	BufferedInputStream screenResized = null;
    	try {
	    	screen = new BufferedInputStream(new FileInputStream(screenShot));
	    	byte[] bytes = new byte[screen.available()];
	    	
	    	
	    	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();
    	}
    	finally {
	    	screen.close();
	    	screenResized.close();
	    	
	    	rsImage.close();
	    	stmt.close();
    	}
    }
    
    public static int executeUpdate(String query) throws SQLException {

    	Statement stmt = null;
    	int result = 0;
    	try {
	    	stmt = conn.createStatement();
	        result = stmt.executeUpdate(query);
    	}
    	finally {
    		stmt.close();
    	}
        return result;
    }

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