database.java

来自「JSP写的一个简单聊天室。不需要连接数据库。实现简单」· Java 代码 · 共 77 行

package database;

import java.sql.*;

public class DataBase {
	private String driver = "COM.ibm.db2.jdbc.app.DB2Driver";

	private String url = "jdbc:db2:chat";

	private Connection conn = null;

	private Statement stmt = null;

	private ResultSet rs = null;

	public DataBase() {
		try {
			Class.forName(driver);
		} catch (Exception e) {
			System.err.println("database():" + e.getMessage());
		}
	}

	public ResultSet executeQuery(String sql) {
		try {
			conn = DriverManager.getConnection(url);
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
		} catch (Exception e) {
			System.out.println("executeQuery:" + e.getMessage());
		}
		return rs;
	}

	public boolean executeUpdate(String sql) {
		boolean b =false;
		try {
			conn = DriverManager.getConnection(url);
			conn.setAutoCommit(false);
			stmt = conn.createStatement();
			try {
				stmt.executeUpdate(sql);
				conn.commit();
				b=true;
			} catch (Exception e) {
				conn.rollback();
				System.out.println("Database Exception:" + e.getMessage());
				b= false;
			}

		} catch (Exception e) {
			System.err.println("executeUpdate:" + e.getMessage());
			b= false;
		}
		return b;
	}
	
	

	public void closeStmt() {
		try {
			stmt.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public void closeConn() {
		try {
			conn.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

}