jdbcbase.java

功能还没做全的选课系统

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();
		}
	}

}