package com.roytel.rtccp.util;
import java.sql.*;
public class dbmanager {
//用户名
private string user = "";
//密码
private string password = "";
//主机
private string host = "";
//数据库名字
private string database = "";
/*
private string url="jdbc:mysql://"+host+"/"+"useunicode=true&characterencoding=gb2312";
*/
private string url ="";
private connection con = null;
statement stmt;
/**
* 根据主机、数据库名称、数据库用户名、数据库用户密码取得连接。
* @param host string
* @param database string
* @param user string
* @param password string
*/
public dbmanager(string host, string database, string user, string password) {
this.host = host;
this.database = database;
this.user = user;
this.password = password;
//显示中文
this.url = "jdbc:mysql://" + host + "/" + database +
"?useunicode=true&characterencoding=gb2312";
try {
class.forname("org.gjt.mm.mysql.driver");
}
catch (classnotfoundexception e) {
system.err.println("class not found:" + e.getmessage());
}
try {
con = drivermanager.getconnection(this.url, this.user, this.password);
//连接类型为resultset.type_scroll_insensitive, resultset.concur_read_only
stmt = con.createstatement(resultset.type_scroll_insensitive,
resultset.concur_read_only);
}
catch (sqlexception a) {
system.err.println("sql exception:" + a.getmessage());
}
}
/**
* 返回取得的连接
*/
public connection getcon() {
return con;
}
/**
* 执行一条简单的查询语句
* 返回取得的结果集
*/
public resultset executequery(string sql) {
resultset rs = null;
try {
rs = stmt.executequery(sql);
}
catch (sqlexception e) {
e.printstacktrace();
}
return rs;
}
/**
* 执行一条简单的更新语句
* 执行成功则返回true
*/
public boolean executeupdate(string sql) {
boolean v = false;
try {
v = stmt.executeupdate(sql) > 0 ? true : false;
}
catch (sqlexception e) {
e.printstacktrace();
}
finally {
return v;
}
}
}
能用的，你可以扩充，比如增加执行预编译语句的方法、执行存储过程的方法，也可以用连接池的方法。