jdbcbean.java

基于MVC模式的文章采集检索系统

package com.liubin.database;

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

public class JdbcBean {
	private Connection conn;
	private Statement st;

	public JdbcBean() {
		try {
			Class.forName("COM.ibm.db2.jdbc.app.DB2Driver");
			conn = DriverManager.getConnection("jdbc:db2:cis");
			st = conn.createStatement();
		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	public ResultSet query(String sql) {
		ResultSet rs = null;
		try {
			rs = st.executeQuery(sql);
			return rs;
		} catch (Exception e) {
			e.printStackTrace();
		}
		return rs;

	}

	public int update(String sql) {
		try {
			return st.executeUpdate(sql);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return 0;
	}

	public void close() {
		try {
			st.close();
			conn.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}

	}
	
	public boolean updateBatch(String[]sqls){
		int[] temp=null;
		try{
			conn.setAutoCommit(false);
			for(int i=0;i<sqls.length;i++){
				st.addBatch(sqls[i]);
			}
			temp=st.executeBatch();
			conn.commit();
		
			
		}
		catch(Exception e){
			try {
				e.printStackTrace();
				conn.rollback();//如果批处理不成功，注意一定要执行回滚操作
			} catch (SQLException e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
			
		}
		if(temp!=null){
			return true;
		}
		else{
			return false;
		}
	}

	

}