package com.xuanke.utils;


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

/*
 * 數據庫相關操作基礎了，完成sql語句的執行，事務管理
 * 該類將被各自子類基礎，完成特定數據庫表、視圖等的操作
 */
public class JDBCBase {
	protected Connection connection;
	public JDBCBase(Connection conn){
		this.connection=conn;
	}
	public ResultSet qry(String sql) throws MyJDBCException{
		try {
			Statement st=this.connection.createStatement();
			return st.executeQuery(sql);
		} catch (SQLException e) {
			// TODO 自動生成 catch 塊
			throw new MyJDBCException("執行sql語句失敗："+sql);
		}
		//本過程Statement 不能關閉，因為調用該過程的程序需要遍歷
		//結果集，需要在遍歷完結果集后執行關閉語句
				
	}
	public int execute(String sql) throws MyJDBCException{
		try {
			Statement st=this.connection.createStatement();
			return st.executeUpdate(sql);
		} catch (SQLException e) {
			// TODO 自動生成 catch 塊
			throw new MyJDBCException("執行sql語句失敗："+sql);
		}
	}
	public void startTransaction()throws MyJDBCException{
		try {
			this.connection.setAutoCommit(false);
		} catch (SQLException e) {
			throw new MyJDBCException("啟動事務失敗");
		}
		
	}
	public void commitTransaction()throws MyJDBCException{
		try {
			this.connection.commit();
		} catch (SQLException e) {
			throw new MyJDBCException("遞交事務失敗");
		}
	}
	public void rollbackTransaction(){
		try {
			this.connection.rollback();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

}