越南做It网站推广,怎样做安居客网站,黄骅港属于哪个区,网站怎么做双语种刚开始接触j2ee的时候总是为数据库的开关连接问题而烦恼,虽然问题很简单却很是琐碎,于是干脆写成一个类将所有必要的基本操作全部总结进去,以后只要轻松的import一下就可以了啊:)菜鸟们enjoying!import java.sql.Connection;import java.sql.Statement;import java.sql.ResultS…刚开始接触j2ee的时候总是为数据库的开关连接问题而烦恼,虽然问题很简单却很是琐碎,于是干脆写成一个类将所有必要的基本操作全部总结进去,以后只要轻松的import一下就可以了啊:)菜鸟们enjoying!import java.sql.Connection;import java.sql.Statement;import java.sql.ResultSet;import java.util.Vector;public class DBConnection {//数据库属性public static String dbDriverName com.microsoft.jdbc.sqlserver.SQLServerDriver;//其他驱动自己填写public static String dbURL jdbc:microsoft:sqlserver://localhost:1433;DatabaseNameDBNAME;public static String dbUserID userid;public static String dbUserPass userpassword;public DBConnection() {}public void open() throws Exception{open( dbDriverName, dbURL, dbUserID, dbUserPass);}/*** 创建一个数据库连接* param driver* JDBC驱动类* param url* 数据库位置* param userID* 数据库登录名* param password* 数据库登录密码* throws Exception* 创建数据库失败*/public void open(String driver, String url,String userID, String password)throws Exception{close();Class.forName(driver);connection java.sql.DriverManager.getConnection(url, userID, password);connected true;}/*** 关闭当前数据库连接*/public void close(){if (connection null )return;try{if ( !connection.isClosed() )connection.close();}catch(Exception e){}connected false;}/*** 判断连接状态* return* 连接返回true,否则返回false;*/public boolean isConnected(){return connected;}public void executeInsert (String sql) throws Exception{check();createStatement();statement.execute(sql);}public void executeBatch(Vector sqls)throws Exception{check();createStatement();for( int i 0; i sqls.size(); i ){String sql (String)sqls.get(i);if ( sql.toLowerCase().trim().startsWith(select)){throw new Exception(Batch 操作不支持Select操作);}statement.addBatch(sql);}statement.executeBatch();}public ResultSet executeSelect (String sql) throws Exception{check();createStatement();statement.execute(sql);return statement.getResultSet();}public int executeUpdate (String sql) throws Exception{check();createStatement();statement.execute(sql);return statement.getUpdateCount();}public int executeDelete (String sql) throws Exception{check();createStatement();statement.execute(sql);return statement.getUpdateCount();}public void execute (String sql) throws Exception{check();createStatement();statement.execute(sql);}public void beginTrans ()throws Exception{check();connection.setAutoCommit(false);}public void commit () throws Exception{check();connection.commit();}public void rollback (){try{connection.rollback();}catch(Exception e){}}public boolean isConnectioned () throws Exception{return connected;}protected void check () throws Exception{if (!connected)throw new Exception(没有创建数据库连接);}public void createStatement() throws Exception{if ( statement null || connection.getAutoCommit() )statement connection.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);}protected Connection connection null;protected boolean connected;protected Statement statement;}
