/**
 * db.java
 * 数据库联接
 * @author Gaowei
 * @version 1.0
 * @2004.3.18
 */
package com.WebSite20.bean
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Date;public class db {
//成员变量初始化
Connection conn = null; //数据库连接
protected ResultSet rs = null; //记录集
int question_Id = 0;
String user_num = null;
String topic = null;
String content = null;
String answer = null;
String answer_name = null;
Date ask_time;
Date answer_time;
//db的构建器
public db() throws IllegalAccessException {
try { try {
Class
.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver")
.newInstance(); } catch (InstantiationException e1) {
System.out.println("error!DAFJL:");
e1.printStackTrace();
}
} catch (java.lang.ClassNotFoundException e) { System.err.println("mydddb(): " + e.getMessage());
}
} //executeQuery方法用于进行记录的查询操作 //入口参数为sql语句,返回ResultSet对象
public ResultSet executeQuery(String sql) {
rs = null;
try {
conn =
DriverManager.getConnection(
"jdbc:microsoft:sqlserver://192.168.0.163:1433;DatabaseName=WebSite20",
"sa",
"century");
Statement stmt = conn.createStatement();
//执行数据库查询操作
rs = stmt.executeQuery(sql);
} catch (SQLException ex) {
System.err.println("db.executeQuery: " + ex.getMessage());
}
return rs;
}
//executeUpdate方法用于进行add或者update记录的操作 //入口参数为sql语句,成功返回true,否则为false
public boolean executeUpdate(String sql) {
boolean bupdate = false;
rs = null;
try {
//建立数据库连接,其它参数说明同上面的一样
conn =
DriverManager.getConnection(
"jdbc:microsoft:sqlserver://192.168.0.163:1433;DatabaseName=WebSite20",
"sa",
"century");
Statement stmt = conn.createStatement();
int rowCount = stmt.executeUpdate(sql);
//如果不成功,bupdate就会返回0
if (rowCount != 0)
bupdate = true;
} catch (SQLException ex) {
//打印出错信息
System.err.println("db.executeUpdate: " + ex.getMessage());
}
return bupdate;
} //toChinese方法用于将一个字符串进行中文处理 //否则将会是???这样的字符串
}