dbconnect.java

JAVA 用于网站开发

package datebase;
import java.sql.*;
import java.io.*;

public class Dbconnect {
	String sDBDriver = "org.gjt.mm.mysql.Driver";

	String sConnStr = "jdbc:mysql://localhost:3306/nsms?useUnicode=true&characterEncoding=GBK";

	Connection connect = null;

	ResultSet rs = null;

	Statement stmt = null;

	public Dbconnect() {
		try {
			Class.forName(sDBDriver);
		} catch (java.lang.ClassNotFoundException e) {
			System.err.println(e.getMessage());
		}
	}

	public ResultSet executeQuery(String sql) {
		try {
			connect = DriverManager.getConnection(sConnStr, "root", "mysql");
			Statement stmt = connect.createStatement();
			rs = stmt.executeQuery(sql);
		} catch (SQLException ex) {
			System.err.println(ex.getMessage());
		}
		return rs;
	}

	// 更新语句
	public void UpdateDate(String sql) {
		try {
			connect = DriverManager.getConnection(sConnStr, "root", "mysql");
			stmt = connect.createStatement();
			stmt.executeUpdate(sql);
			this.close();

		} catch (SQLException ex) {
			System.err.println(ex.getMessage());
		}
	}

	public int executeUpdate(String sql) {
		int result = 0;
		try {
			connect = DriverManager.getConnection(sConnStr, "root", "mysql");
			Statement stmt = connect.createStatement();
			result = stmt.executeUpdate(sql);
		} catch (SQLException ex) {
			System.err.println(ex.getMessage());
		}
		return result;
	}

	public void close() {
		/* rs */
		try {
			if (rs != null)
				rs.close();
		} catch (Exception e) {
			System.out.println("rs");
			System.out.println("e.getMessage");
			e.printStackTrace();
		}
		/* stmt */
		try {
			if (stmt != null)
				stmt.close();
		} catch (Exception e) {
			System.out.println("stmt");
			System.out.println("e.getMessage");
			e.printStackTrace();
		}
		/* con */
		try {
			if (connect != null)
				connect.close();
		} catch (Exception e) {
			System.out.println("connect");
			System.out.println("e.getMessage");
			e.printStackTrace();
		}
	}
}