package bit.jeffy.db;

import java.sql.*;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

/*
 * 創建日期 2005-4-7
 *
 * TODO 要更改此生成的文件的模板，請轉至
 * 窗口 － 首選項 － Java － 代碼樣式 － 代碼模板
 */

/**
 * @author jeffy522
 * 
 * TODO 要更改此生成的類型注釋的模板，請轉至 窗口 － 首選項 － Java － 代碼樣式 － 代碼模板
 */
public class DataStore {

	private static DataStore db = null;

	private static Connection conn = null;

	private Statement stmt = null;
	
	private boolean hadErrors = false;

	private DataStore() throws Exception {
		if (conn == null) {
			Class.forName("com.mysql.jdbc.Driver");
			conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydatabase", "root",
					"1");
			stmt = conn.createStatement();
		}
	}
	
	public void beginTransaction() throws SQLException
    {
		conn.setAutoCommit(false);
    }
	
	public void commitTransaction() throws SQLException
    {
        if( !hadErrors ){
            conn.commit();
        }
        else{
        	conn.rollback();
        	hadErrors = false;
        }       

        hadErrors = false;
        conn.setAutoCommit(true);
    }

	public void ErrorOccur( ){
		hadErrors = true;
	}
	
	public static DataStore getInstance() {
		if (db == null) {
			try {
				db = new DataStore();
			} catch (Exception e) {
				conn = null;
				Log log = LogFactory.getLog("mylog");
				log.error("數據庫連接出錯-DataStore.java");
				return null;
			}
		}
		return db;

	}

	synchronized public void execute(String sql){
		try{
			if (stmt != null)
				stmt.executeUpdate(sql);
			else {
				Log log = LogFactory.getLog("mylog");
				log.error("數據庫插入數據出錯");
			}
		}catch(SQLException e){
			
		}
	}

	synchronized public ResultSet read(String sql){
		ResultSet tmp = null;
		
		try{
			if (stmt != null) {
				tmp = stmt.executeQuery(sql);
				return tmp;
			} else {
				return null;
			}
		}catch(SQLException e){
			return null;
		}
	}
	
	synchronized public int readCount( String sql ){
		int nCount = 0;
		
		try {
			if( stmt != null ) {
				ResultSet tmp = null;
				tmp = stmt.executeQuery(sql);
				if( tmp!=null && tmp.next() ) {
					nCount = tmp.getInt(1);
				}else {
					nCount = 0;
				}
			}else {
				nCount = 0;
			}
		}catch(SQLException e) {
			nCount = 0;
		}
		
		return nCount;
	}

	synchronized public void stop() {
		try {
			if (conn != null) {
				conn.close();
				stmt.close();
			}
		} catch (Exception e) {
			/* 記錄到日志 */
			Log log = LogFactory.getLog("mylog");
			log.error("數據庫關閉出錯-DataStore.java");
		} finally {
			conn = null;
		}
	}
}