package cn.com.bj95ol.wap.readexcel;

import java.sql.*;
;

public class DBManager {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub

	}
	private String classname = "org.gjt.mm.mysql.Driver";

//	private String url = "jdbc:mysql://218.206.73.85:3306/WAP_TEST?useUnicode=true&characterEncoding=utf8";
	private String url = "jdbc:mysql://localhost:3306/DB_WAP?useUnicode=true&characterEncoding=utf8";
//	private String pwd = "9518bjjwzx";
//	private String pwd = "1q2w3e4r";
	private String pwd = "9501";
	
	private String user = "root";
	
	private Connection conn=null;
	
	private Statement stmt = null;

	private PreparedStatement ps = null;

	private boolean initialized = false;



	public DBManager() {
		if (!initialized) {
			createcon();
			if (conn == null)
				System.out.println("數據庫連接失敗！！");
		}
	}
	
	public DBManager(String driver,String addr,String name,String pass) {
		classname=driver;
		url=addr;
		user=name;
		pwd=pass;
		if (!initialized) {
			createcon();
			if (conn == null)
				System.out.println("數據庫連接失敗！！");
		}
	}
	
	public void createcon() {
		try {
			Class.forName(classname);
			conn = DriverManager.getConnection(url, user, pwd);

			//System.out.println("database init");
			initialized = true;
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	public Connection getConnection(){
		return conn;
	}
	public Statement getStatement(){
		//Statement stmt=null;
		try{
			if(conn!=null)
				stmt=conn.createStatement();
			else
				System.out.println("未建立數據庫連接");
		}catch(Exception e){
			e.printStackTrace();
		}
		return stmt;
	}
	
	public PreparedStatement getPreparedStatement(String sql){
		//PreparedStatement ps=null;
		try{
			if(conn!=null)
				ps=conn.prepareStatement(sql);
			else
				System.out.println("未建立數據庫連接");
		}catch(Exception e){
			e.printStackTrace();
		}
		return ps;
	}
	
	public ResultSet query(String sql){
		ResultSet rs=null;
		try{
			if(conn!=null)
			{
				stmt=conn.createStatement();
				rs=stmt.executeQuery(sql);
				System.out.println("ok");
			}
			else
				System.out.println("未建立數據庫連接");
		}catch(Exception e){
			e.printStackTrace();
		}
		return rs;
	}
	
	public int update(String sql){
		int ret=-100;
		try{
			if(conn!=null)
			{
				stmt=conn.createStatement();
				ret=stmt.executeUpdate(sql);
			}
			else
				System.out.println("未建立數據庫連接");
		}catch(Exception e){
			e.printStackTrace();
		}
		return ret;
	}
	public void close() {
		try {
			
			if (stmt != null)
				stmt.close();
			if (ps != null)
				ps.close();
			if (conn != null)
				conn.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}