JSP在线阅读系统myeclipse定制开发SQLServer数据库网页模式java编程jdbc源码

package com.util; import java.sql.*; import javax.activation.DataSource; import java.sql.*; import javax.naming.Context; import javax.naming.InitialContext; import java.util.*; public class DBO { private Connection conn; private Statement stmt; private DataSource ds; public DBO() { open(); } /** 打开数据库 */ public void open() { try { //Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver"); //conn = DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;databasename=jxpj","sa","abc123"); Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");//sql2005 String dbURL = "jdbc:sqlserver://localhost:1433; DatabaseName=jspzxyd"; //连接服务器和数据库sample 2005 String userName = "sa"; //默认用户名 String userPwd = "abc123"; //密码 conn = DriverManager.getConnection(dbURL, userName, userPwd); stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY); System.out.println("打开数据库连接"); } catch (Exception ex) { System.err.println("打开数据库时出错: " + ex.getMessage()); } } /** 关闭数据库，将连接返还给连接池 */ public void close() { try { // connMgr.freeConnection("java", conn); conn.close(); System.out.println ("释放连接"); } catch (SQLException ex) { System.err.println("返还连接池出错: " + ex.getMessage()); } } /** 执行查询 */ public ResultSet executeQuery(String sql) throws SQLException { ResultSet rs = null; rs = stmt.executeQuery(sql); System.out.println ("执行查询"); return rs; } public ResultSet query(String sql) throws SQLException { ResultSet rs = null; rs = stmt.executeQuery(sql); System.out.println ("执行查询"); return rs; } /** 执行增删改 */ public int executeUpdate(String sql) throws SQLException { int ret = 0; ret = stmt.executeUpdate(sql); System.out.println ("执行增删改"); return ret; } public int update(String sql) throws SQLException { int ret = 0; ret = stmt.executeUpdate(sql); System.out.println ("执行增删改"); return ret; } /** 将SQL语句加入到批处理 */ public void addBatch(String sql) throws SQLException { stmt.addBatch(sql); } /** 执行批处理 */ public int [] executeBatch() throws SQLException { boolean isAuto=conn.getAutoCommit(); conn.setAutoCommit(false); int [] updateCounts = stmt.executeBatch(); // conn.commit(); // conn.setAutoCommit(isAuto); //conn.setAutoCommit(true); return updateCounts; } public boolean getAutoCommit() throws SQLException { return conn.getAutoCommit(); } public void setAutoCommit(boolean auto) throws SQLException { conn.setAutoCommit(auto); } public void commit() throws SQLException { conn.commit(); // this.close(); } public void rollBack() throws SQLException { conn.rollback(); // this.close(); } public static void main(String[] args) { DBO con= new DBO(); //con.open(); ResultSet rs=null; String sql="select id dd from didian"; con.close(); } }