package datebase;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import javax.sql.DataSource;

public class DB {
	Connection connect = null;
	ResultSet rs = null;
	public DB(DataSource dataSource) {
		
		try {
			connect = dataSource.getConnection();
		}
		catch(SQLException e) {
			System.out.println("connect   fail");
			e.printStackTrace();
		}
	}
	
	public ResultSet OpenSqlQuery(String sql) {
		try {
			Statement stmt = connect.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
			rs = stmt.executeQuery(sql);
		} 
		catch(SQLException ex) { 
			System.out.println("query   error");
			ex.printStackTrace();
		}
		return rs;
	}
	
	public int ExecSqlUpdate(String sql) {
		int result = 0;
		try {
			Statement stmt = connect.createStatement();
			result = stmt.executeUpdate(sql);
		} 
		catch(SQLException ex) { 
			
			System.err.println(ex.getMessage());
			
		}
		return result;
	}
	
	public void close(){
		if(connect!=null){
			try{
				connect.close();
				connect = null;	
			}catch(SQLException ex) { 
				System.err.println(ex.getMessage());
			}
		}	
	}
}