fatkun's blog

package DB;
 
import java.sql.*;
 
public class Conn {
	private String db = "test"; // 数据库名
	private String user = "root"; // 数据库用户名
	private String pass = ""; // 数据库密码
	private String drivername = "com.mysql.jdbc.Driver"; // mysql driver
	private String URL = "jdbc:mysql://localhost:3306/" + db
			+ "?useUnicode=true&characterEncoding=UTF8&user=" + user
			+ "&password=" + pass;
	private Connection conn = null;
 
	public Conn(){
		conn = this.getConn();
	}
 
	public Connection getConn() { // get database connection
		Connection aconn = null;
		try {
			Class.forName(drivername).newInstance(); // 载入驱动器
			aconn = DriverManager.getConnection(URL); // 连接到数据库
		} catch (Exception e) {
			e.printStackTrace();
		}
		return aconn;
	}
 
	public ResultSet executeQuery(String str) {
		ResultSet rs = null;
		try {
			Statement stmt = conn.createStatement(); // 语句接口
			rs = stmt.executeQuery(str); // 获得结果集
		} catch (Exception e) {
			e.printStackTrace();
		}
		return rs;
	}
 
	public int executeUpdate(String str) {
		int ret = 0;
		try {
			Statement stmt = conn.createStatement();
			ret = stmt.executeUpdate(str);//执行sql语句，返回影响行数
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return ret;
	}
 
}