sqlbean.java

一个学生课绩管理系统

package database;

import java.io.*;
import java.sql.*;

public class sqlBean {

	private Connection conn = null;

	private ResultSet rs = null;

	// 数据库驱动
	private String DatabaseDriver = "com.mysql.jdbc.Driver";

	// 数据源URL
	private String DatabaseConnStr = "jdbc:mysql://localhost:3306/stuArchiveDB,'root',111";

	public sqlBean() {
		try {
			// 加载驱动
			Class.forName(DatabaseDriver);
		} catch (java.lang.ClassNotFoundException e) {
			System.err.println("加载驱动器有错误:" + e.getMessage());
			// 输出到客户端
			System.out.print("执行插入有错误:" + e.getMessage());
		}
	}

	// SQL INSERT, UPDATE or DELETE
	public int executeUpdate(String sql) {
		int num = 0;
		try {
			conn = DriverManager.getConnection(DatabaseConnStr);
			Statement stmt = conn.createStatement();
			num = stmt.executeUpdate(sql);
		} catch (SQLException ex) {
			System.err.println("执行有错误:" + ex.getMessage());
			// 输出到客户端
			System.out.print("执行有错误:" + ex.getMessage());
		}
		CloseDataBase();
		return num;
	}

	// SQL query
	public ResultSet executeQuery(String sql) {
		rs = null;
		try {
			conn = DriverManager.getConnection("jdbc:odbc:ClassDB", "limq",
					"123");
			Statement stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
		} catch (SQLException ex) {
			System.err.println("执行查询有错误:" + ex.getMessage());
			System.out.print("执行查询有错误:" + ex.getMessage()); // 输出到客户端
		}
		return rs;
	}

	public void CloseDataBase() {
		try {
			conn.close();
		} catch (Exception end) {
			System.err.println("执行关闭Connection对象有错误：" + end.getMessage());
			// 输出到客户端
			System.out.print("执行执行关闭Connection对象有错误：有错误:" + end.getMessage());
		}
	}

	public String getDatabaseDriver() {
		return (this.DatabaseDriver);
	}

	public void setDatabaseDriver(String strSet) {
		this.DatabaseDriver = strSet;
	}

	public String getDatabaseConnStr() {
		return (this.DatabaseConnStr);
	}

	public void setDatabaseConnStr(String ConnStr) {
		this.DatabaseConnStr = ConnStr;
	}
}