dboper.java

jsp+javabean+sqlserver开发的设备管理系统

package devicecomm;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DBOper {
    private Connection conn = null;
    private Statement stmt = null;
    // 数据库连接
	public void connectDB() throws Exception
	{
		String hostName       = "localhost";   // 主机名或者IP地址
        String portNumber     = "1433";       // 端口号，默认为1521
        String databaseSID    = "dlsz";   // SID名称
        String userName       = "sa";     // 用户名
        String password       = "";     // 用户密码   
		String url = "jdbc:microsoft:sqlserver://"+hostName+":"+portNumber+";databaseName="+databaseSID;   // 连接字符串
		System.out.println(url);  // 打印连接字符串
		try{
			// 装载驱动程序
			Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
			// 建立连接
			conn = DriverManager.getConnection(url,userName,password);
        }
        catch (Exception e){
			// 如果有异常，则抛出错误
            System.out.println("=====Exception : DBOper connectDB() exception: " + e.getMessage());
        }
    }
	// 获取数据库连接对象
	public Connection getConnection() throws Exception
	{
		return conn;
	}
	// 执行查询，返回单一结果
    public ResultSet getResultSet(String sql) throws SQLException
    {
        try{
			// 如果数据库没有连接，则连接数据库
			if(conn==null)
				connectDB();
        }
        catch (Exception e){
            throw new SQLException(e.getMessage());
        }
		// 如果语句为空，则创建语句
 		if(stmt ==null)
         stmt =conn.createStatement();
		// 执行查询，返回查询结果集
       return stmt.executeQuery(sql);
    }
	// 添加、删除、更新操作
    public void DataUpdate(String sql) throws SQLException
    {
        try
        {
			// 连接数据库
			if(conn==null)
				connectDB();
		   // 创建语句
			if(stmt ==null)
			 stmt =conn.createStatement();
		   // 执行更新操作
           stmt.executeUpdate(sql);
        }
        catch (Exception e)
        {
            throw new SQLException(e.getMessage());
        }
	}
    // 关闭
    public void close() throws SQLException
    {
		// 设置自动提交
		conn.setAutoCommit(true);
		// 关闭语句，关闭连接
        if(stmt!=null) {stmt.close();stmt  =null;}
        if(conn!=null) {conn.close();conn  =null;}
    }
}