sqlbean.java

在线教育平台： 从小学

package edu;


import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

public class SqlBean {// /

	private String DatabaseDriver;
	private String DatabaseConnStr;
	private String user;
	private String psw;
	public Connection conn = null;

	public ResultSet rs = null;
	public SqlBean() {// ///构造函数
		init();

		try {

			Class.forName(DatabaseDriver);
		} catch (java.lang.ClassNotFoundException e) {
			System.err.println("加载驱动器有错误:" + e.getMessage());
			System.out.print("执行插入有错误:" + e.getMessage());// 输出到客户端
		}
	}
	//private String DatabaseDriver = "org.gjt.mm.mysql.Driver";
	//private String DatabaseDriver = "org.logicalcobwebs.proxool.ProxoolDriver";
	// DataSource 数据源名称DSN jdbc:mysql://SQL06.FREEMYSQL.NET/xdfedu
	//jdbc:mysql://localhost/edu
	//jdbc:mysql://s42.eatj.com/xdf007
	// private String DatabaseConnStr="jdbc:odbc:ClassDB,'limq',123";
	//private String DatabaseConnStr = "jdbc:mysql://localhost/edu?useUnicode=true&characterEncoding=gbk";
	//private String DatabaseConnStr = "proxool.Develop";
	//private String strcon = "proxool.Develop";

	//private String strcon = "proxool.example:org.gjt.mm.mysql.Driver:jdbc:mysql://localhost/edu?useUnicode=true&characterEncoding=gbk";

	//private String user = "root";

	//private String psw = "1984714";

	// 定义方法
	/* setXxx用于设置属性值;getXxx用于得到属性值 */
	public void setDatabaseDriver(String Driver) {
		this.DatabaseDriver = Driver;
	}

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

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

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


	private void init() {
		  InputStream is = getClass().getResourceAsStream("/edu/db.properties");
		  Properties dbProps = new Properties();
		  try {
		    dbProps.load(is);
		  }
		  catch (Exception e) {
		    System.err.println("不能读取属性文件. " +
		   "请确保db.properties在CLASSPATH指定的路径中");
		    return;
		  }
		 DatabaseDriver = dbProps.getProperty("driver");    
		 DatabaseConnStr =dbProps.getProperty("url");
		 user =dbProps.getProperty("user");
		 psw =dbProps.getProperty("psw");

		 }



	public int executeInsert(String sql) {
		int num = 0;
		try {
			// conn =
			// DriverManager.getConnection("jdbc:odbc:ClassDB","limq","123");
			conn = DriverManager.getConnection(DatabaseConnStr,user,psw);
			Statement stmt = conn.createStatement();
			num = stmt.executeUpdate(sql);
		} catch (SQLException ex) {
			System.err.println("执行插入有错误:" + ex.getMessage());
			System.out.print("执行插入有错误:" + ex.getMessage());// 输出到客户端
		}
		CloseDataBase();
		return num;
	}

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

	// delete data
	public int executeDelete(String sql) {
		int num = 0;
		try {
			// conn =
			// DriverManager.getConnection("jdbc:odbc:ClassDB","limq","123");
			conn = DriverManager.getConnection(DatabaseConnStr,user,psw);

			Statement stmt = conn.createStatement();
			num = stmt.executeUpdate(sql);
		} catch (SQLException ex) {
			System.err.println("执行删除有错误:" + ex.getMessage());
			System.out.print("执行删除有错误:" + ex.getMessage()); // 输出到客户端
		}
		CloseDataBase();
		return num;
	}

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