JDBC的一个连接池,在我们项目中用到的。
2004-10-30 15:12
363 查看
<script type="text/javascript"><!--
google_ad_client = "pub-2016433482135581";
google_ad_width = 728;
google_ad_height = 90;
google_ad_format = "728x90_as";
google_ad_channel ="";
//--></script>
<script type="text/javascript"
src="http://pagead2.googlesyndication.com/pagead/show_ads.js">
</script>
package dbconnection;
import javax.servlet.http.*;
import java.io.*;
import java.sql.*;
import javax.naming.*;
import javax.sql.*;
import org.apache.commons.dbcp.BasicDataSource;
import org.apache.commons.dbutils.DbUtils;
public class DBConnection implements Serializable{
private java.lang.String dbUserID;
private java.lang.String dbPassword;
private java.lang.String dbDriver;
private java.lang.String dbURL;
private java.lang.String sqlString;
private java.sql.ResultSet result;
private java.sql.ResultSetMetaData meta;
private java.sql.Connection conn;
private java.sql.Statement sqlStmt;
private java.lang.String drcName;
private final static java.lang.String className = "dbconnection.DBConnection";
private java.lang.String initialContext;
/**
* DBConnection constructor comment.
*/
public DBConnection (){
super ();
}
/**
* Insert the method's description here.
* Creation date: (10/31/00 3:44:45 PM)
*/
public void close (){
String methodName = "close()";
DBConnection.closeResultSetAndStatement (sqlStmt, result);
DBConnection.closeConnection (conn);
}
/**
* Insert the method's description here.
* Creation date: (7/25/2003 5:34:40 PM)
*/
public void closeStatement (){
try{
if (sqlStmt != null){
sqlStmt.clearBatch ();
sqlStmt.clearWarnings ();
sqlStmt.close ();
}
} catch (SQLException e){
}
}
/**
* Insert the method's description here.
* Creation date: (11/2/00 10:51:57 AM)
* @exception java.sql.SQLException The exception description.
*/
public void commit (){
String methodName = "commit()";
try{
if (conn != null && !conn.isClosed ()){
conn.commit ();
}
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
}
/**
* Insert the method's description here.
* Creation date: (10/6/00 4:04:34 PM)
*/
public void connect (){
String methodName = "connect()";
try{
if (conn == null){
if (!registerDriver (dbDriver)){
throw new SQLException ("Can't load JDBC Driver - " + dbDriver + ".");
}
/*
InitialContext context = new InitialContext ();
DataSource ds = (DataSource)context.lookup (drcName);
*/
DataSource ds = setupDataSource ();
Connection connection = ds.getConnection ();
conn = connection;
}
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
/*
catch (NamingException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
*/
}
/**
* Insert the method's description here.
* Creation date: (10/16/00 2:17:02 PM)
* @return dbconnection.DBConnection
*/
public static DBConnection dbconnect (){
String methodName = "dbconnect(String, String)";
DBConnection dbconn = null;
try{
// initialize dbconnection
dbconn = new DBConnection ();
// Get DB connection parameters from central getDBConnectionParm bean
getParm getDBConnectionParm = new getParm ();
getDBConnectionParm.init ();
dbconn.setDbUserID (getDBConnectionParm.getParameter ("userID"));
// out.println("After setDbUserID");
dbconn.setDbPassword (getDBConnectionParm.getParameter ("password"));
dbconn.setDbURL (getDBConnectionParm.getParameter ("URL"));
dbconn.setDbDriver (getDBConnectionParm.getParameter ("driver"));
dbconn.setDrcName (getDBConnectionParm.getParameter (
"ConnectionPoolLocation"));
dbconn.setInitialContext (getDBConnectionParm.getParameter (
"initial_context"));
System.out.println (dbconn.getDbUserID () + ", " + dbconn.getDbPassword () +
", " + dbconn.getDbURL () + ", " + dbconn.getDbDriver () +
", " + dbconn.getDrcName () + ", " +
dbconn.getInitialContext ());
dbconn.connect ();
System.out.println ("After dbconn.connect()");
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
} catch (Exception e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
e.printStackTrace ();
}
return dbconn;
}
public static DBConnection dbconnect (String filename){
String methodName = "dbconnect(String, String)";
DBConnection dbconn = null;
try{
// initialize dbconnection
dbconn = new DBConnection ();
// Get DB connection parameters from central getDBConnectionParm bean
getParm getDBConnectionParm = new getParm ();
getDBConnectionParm.init (filename);
dbconn.setDbUserID (getDBConnectionParm.getParameter ("userID"));
// out.println("After setDbUserID");
dbconn.setDbPassword (getDBConnectionParm.getParameter ("password"));
dbconn.setDbURL (getDBConnectionParm.getParameter ("URL"));
dbconn.setDbDriver (getDBConnectionParm.getParameter ("driver"));
dbconn.setDrcName (getDBConnectionParm.getParameter (
"ConnectionPoolLocation"));
dbconn.setInitialContext (getDBConnectionParm.getParameter (
"initial_context"));
System.out.println (dbconn.getDbUserID () + ", " + dbconn.getDbPassword () +
", " + dbconn.getDbURL () + ", " + dbconn.getDbDriver () +
", " + dbconn.getDrcName () + ", " +
dbconn.getInitialContext ());
dbconn.connect ();
System.out.println ("After dbconn.connect()");
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
} catch (Exception e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
return dbconn;
}
/**
* This method have Response Object to allow you to print some information on the browser.
* Creation date: (9/29/00 4:35:14 PM)
*/
private void execute (String sqltype) throws SQLException{
if (conn != null && !conn.isClosed ()){
sqlStmt = conn.createStatement ();
sqlStmt.executeQuery (getSqlString ());
if (sqltype.equals ("s") || sqltype.equals ("S")){
result = sqlStmt.getResultSet ();
meta = result.getMetaData ();
}
}
}
/**
* This method have Response Object to allow you to print some information on the browser.
* Creation date: (9/29/00 4:35:14 PM)
*/
public void execute (String sqlString, String sqlType) throws SQLException{
this.sqlString = sqlString;
execute (sqlType);
}
/**
* Insert the method's description here.
* Creation date: (10/6/00 4:04:06 PM)
* @return java.sql.Connection
*/
public java.sql.Connection getConn (){
return conn;
}
/**
* return the driver of db
* Creation date: (9/29/00 4:29:45 PM)
* @return java.lang.String
*/
public java.lang.String getDbDriver (){
return dbDriver;
}
/**
* return the password of db
* Creation date: (9/29/00 4:29:25 PM)
* @return java.lang.String
*/
public java.lang.String getDbPassword (){
return dbPassword;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:34:01 PM)
* @return java.lang.String
*/
public java.lang.String getDbURL (){
return dbURL;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:29:04 PM)
* @return java.lang.String
*/
public java.lang.String getDbUserID (){
return dbUserID;
}
/**
* Insert the method's description here.
* Creation date: (7/17/2002 12:17:51 PM)
* @return java.lang.String
*/
public java.lang.String getDrcName (){
return drcName;
}
/**
* Insert the method's description here.
* Creation date: (10/8/02 10:07:36 AM)
* @return java.lang.String
*/
public java.lang.String getInitialContext (){
return initialContext;
}
/**
* Insert the method's description here.
* Creation date: (10/2/00 1:35:04 PM)
* @return java.sql.ResultSetMetaData
*/
public java.sql.ResultSetMetaData getMeta (){
return meta;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 5:05:13 PM)
* @return java.sql.ResultSet
*/
public java.sql.ResultSet getResult (){
return result;
}
/**
* Insert the method's description here.
* Creation date: (10/6/00 4:06:40 PM)
* @return java.sql.Statement
*/
public java.sql.Statement getSqlStmt (){
return sqlStmt;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:55:48 PM)
* @return java.lang.String
*/
public java.lang.String getSqlString (){
return sqlString;
}
/**
* Insert the method's description here.
* Creation date: (7/18/02 5:05:30 PM)
*/
public void rollback (){
try{
if (conn != null && !conn.isClosed ()){
conn.rollback ();
}
} catch (SQLException e){
}
}
/**
* Insert the method's description here.
* Creation date: (7/18/02 5:04:34 PM)
* @param autoCommit boolean
*/
public void setAutoCommit (boolean autoCommit){
String methodName = "setAutoCommit()";
try{
if (conn != null && !conn.isClosed ()){
conn.setAutoCommit (autoCommit);
}
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
}
/**
* Insert the method's description here.
* Creation date: (10/6/00 4:04:06 PM)
* @param newConn java.sql.Connection
*/
public void setConn (java.sql.Connection newConn){
conn = newConn;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:29:45 PM)
* @param newDbDriver java.lang.String
*/
public void setDbDriver (java.lang.String newDbDriver){
dbDriver = newDbDriver;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:29:25 PM)
* @param newDbPassword java.lang.String
*/
public void setDbPassword (java.lang.String newDbPassword){
dbPassword = newDbPassword;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:34:01 PM)
* @param newDbURL java.lang.String
*/
public void setDbURL (java.lang.String newDbURL){
dbURL = newDbURL;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:29:04 PM)
* @param newDbUserID java.lang.String
*/
public void setDbUserID (java.lang.String newDbUserID){
dbUserID = newDbUserID;
}
/**
* Insert the method's description here.
* Creation date: (7/17/2002 12:17:51 PM)
* @param newDrcName java.lang.String
*/
public void setDrcName (java.lang.String newDrcName){
drcName = newDrcName;
}
/**
* Insert the method's description here.
* Creation date: (10/8/02 10:07:36 AM)
* @param newInitialContext java.lang.String
*/
public void setInitialContext (java.lang.String newInitialContext){
initialContext = newInitialContext;
}
/**
* Insert the method's description here.
* Creation date: (10/2/00 1:35:04 PM)
* @param newMeta java.sql.ResultSetMetaData
*/
public void setMeta (java.sql.ResultSetMetaData newMeta){
meta = newMeta;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 5:05:13 PM)
* @param newResult java.sql.ResultSet
*/
void setResult (java.sql.ResultSet newResult){
result = newResult;
}
/**
* Insert the method's description here.
* Creation date: (10/6/00 4:06:40 PM)
* @param newSqlStmt java.sql.Statement
*/
public void setSqlStmt (java.sql.Statement newSqlStmt){
sqlStmt = newSqlStmt;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:55:48 PM)
* @param newSqlString java.lang.String
*/
private void setSqlString (java.lang.String newSqlString){
sqlString = newSqlString;
}
public DataSource setupDataSource (){
BasicDataSource ds = new BasicDataSource ();
ds.setDriverClassName (dbDriver);
ds.setUsername (dbUserID);
ds.setPassword (dbPassword);
ds.setUrl (dbURL);
return ds;
}
public boolean registerDriver (String driverName){
return DbUtils.loadDriver (driverName);
}
public static void closeResultSetAndStatement (java.sql.ResultSet rs){
String methodName = "closeResultSetAndStatement(java.sql.ResultSet)";
java.sql.Statement stmt = null;
try{
stmt = rs.getStatement ();
} catch (java.sql.SQLException e){
System.err.println ("com.netstarmacau.sampleorder.util.DbConnection.closeResultSetAndStatement(Resultset) ==> " +
e.getMessage ());
} finally{
closeResultSetAndStatement (stmt, rs);
}
}
public static void closeResultSetAndStatement (java.sql.Statement stmt){
String methodName = "closeResultSetAndStatement(java.sql.Statement)";
java.sql.ResultSet rs = null;
try{
rs = stmt.getResultSet ();
} catch (java.sql.SQLException e){
System.err.println ("com.netstarmacau.sampleorder.util.DbConnection.closeResultSetAndStatement(Resultset) ==> " +
e.getMessage ());
} finally{
closeResultSetAndStatement (stmt, rs);
}
}
public static void closeResultSetAndStatement (java.sql.Statement stmt,
java.sql.ResultSet rs){
String methodName =
"closeResultSetAndStatement(java.sql.Statement, ava.sql.ResultSet)";
closeResultSet (rs);
closeStatement (stmt);
}
public static void closeStatement (java.sql.Statement stmt){
DbUtils.closeQuietly (stmt);
}
public static void closeResultSet (java.sql.ResultSet rs){
DbUtils.closeQuietly (rs);
}
public static void closeConnection (Connection conn){
DbUtils.closeQuietly (conn);
}
public static void closeAll (Connection conn, Statement stmt, ResultSet rs){
DbUtils.closeQuietly (conn, stmt, rs);
}
public static void closeAll (DBConnection dbconn, Statement stmt,
ResultSet rs){
if (dbconn != null){
dbconn.close ();
}
closeResultSetAndStatement (stmt, rs);
}
public static void commit (Connection conn){
String methodName = "commit()";
try{
if (conn != null && !conn.isClosed ()){
conn.commit ();
}
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
}
public static void setAutoCommit (Connection conn, boolean autoCommit){
String methodName = "setAutoCommit()";
try{
if (conn != null && !conn.isClosed ()){
conn.setAutoCommit (autoCommit);
}
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
}
public static void rollback (Connection conn){
String methodName = "rollback()";
try{
if (conn != null && !conn.isClosed ()){
conn.rollback ();
}
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
}
public static void closePrePareStatement (java.sql.PreparedStatement pstmt){
DbUtils.closeQuietly (pstmt);
}
}
google_ad_client = "pub-2016433482135581";
google_ad_width = 728;
google_ad_height = 90;
google_ad_format = "728x90_as";
google_ad_channel ="";
//--></script>
<script type="text/javascript"
src="http://pagead2.googlesyndication.com/pagead/show_ads.js">
</script>
package dbconnection;
import javax.servlet.http.*;
import java.io.*;
import java.sql.*;
import javax.naming.*;
import javax.sql.*;
import org.apache.commons.dbcp.BasicDataSource;
import org.apache.commons.dbutils.DbUtils;
public class DBConnection implements Serializable{
private java.lang.String dbUserID;
private java.lang.String dbPassword;
private java.lang.String dbDriver;
private java.lang.String dbURL;
private java.lang.String sqlString;
private java.sql.ResultSet result;
private java.sql.ResultSetMetaData meta;
private java.sql.Connection conn;
private java.sql.Statement sqlStmt;
private java.lang.String drcName;
private final static java.lang.String className = "dbconnection.DBConnection";
private java.lang.String initialContext;
/**
* DBConnection constructor comment.
*/
public DBConnection (){
super ();
}
/**
* Insert the method's description here.
* Creation date: (10/31/00 3:44:45 PM)
*/
public void close (){
String methodName = "close()";
DBConnection.closeResultSetAndStatement (sqlStmt, result);
DBConnection.closeConnection (conn);
}
/**
* Insert the method's description here.
* Creation date: (7/25/2003 5:34:40 PM)
*/
public void closeStatement (){
try{
if (sqlStmt != null){
sqlStmt.clearBatch ();
sqlStmt.clearWarnings ();
sqlStmt.close ();
}
} catch (SQLException e){
}
}
/**
* Insert the method's description here.
* Creation date: (11/2/00 10:51:57 AM)
* @exception java.sql.SQLException The exception description.
*/
public void commit (){
String methodName = "commit()";
try{
if (conn != null && !conn.isClosed ()){
conn.commit ();
}
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
}
/**
* Insert the method's description here.
* Creation date: (10/6/00 4:04:34 PM)
*/
public void connect (){
String methodName = "connect()";
try{
if (conn == null){
if (!registerDriver (dbDriver)){
throw new SQLException ("Can't load JDBC Driver - " + dbDriver + ".");
}
/*
InitialContext context = new InitialContext ();
DataSource ds = (DataSource)context.lookup (drcName);
*/
DataSource ds = setupDataSource ();
Connection connection = ds.getConnection ();
conn = connection;
}
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
/*
catch (NamingException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
*/
}
/**
* Insert the method's description here.
* Creation date: (10/16/00 2:17:02 PM)
* @return dbconnection.DBConnection
*/
public static DBConnection dbconnect (){
String methodName = "dbconnect(String, String)";
DBConnection dbconn = null;
try{
// initialize dbconnection
dbconn = new DBConnection ();
// Get DB connection parameters from central getDBConnectionParm bean
getParm getDBConnectionParm = new getParm ();
getDBConnectionParm.init ();
dbconn.setDbUserID (getDBConnectionParm.getParameter ("userID"));
// out.println("After setDbUserID");
dbconn.setDbPassword (getDBConnectionParm.getParameter ("password"));
dbconn.setDbURL (getDBConnectionParm.getParameter ("URL"));
dbconn.setDbDriver (getDBConnectionParm.getParameter ("driver"));
dbconn.setDrcName (getDBConnectionParm.getParameter (
"ConnectionPoolLocation"));
dbconn.setInitialContext (getDBConnectionParm.getParameter (
"initial_context"));
System.out.println (dbconn.getDbUserID () + ", " + dbconn.getDbPassword () +
", " + dbconn.getDbURL () + ", " + dbconn.getDbDriver () +
", " + dbconn.getDrcName () + ", " +
dbconn.getInitialContext ());
dbconn.connect ();
System.out.println ("After dbconn.connect()");
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
} catch (Exception e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
e.printStackTrace ();
}
return dbconn;
}
public static DBConnection dbconnect (String filename){
String methodName = "dbconnect(String, String)";
DBConnection dbconn = null;
try{
// initialize dbconnection
dbconn = new DBConnection ();
// Get DB connection parameters from central getDBConnectionParm bean
getParm getDBConnectionParm = new getParm ();
getDBConnectionParm.init (filename);
dbconn.setDbUserID (getDBConnectionParm.getParameter ("userID"));
// out.println("After setDbUserID");
dbconn.setDbPassword (getDBConnectionParm.getParameter ("password"));
dbconn.setDbURL (getDBConnectionParm.getParameter ("URL"));
dbconn.setDbDriver (getDBConnectionParm.getParameter ("driver"));
dbconn.setDrcName (getDBConnectionParm.getParameter (
"ConnectionPoolLocation"));
dbconn.setInitialContext (getDBConnectionParm.getParameter (
"initial_context"));
System.out.println (dbconn.getDbUserID () + ", " + dbconn.getDbPassword () +
", " + dbconn.getDbURL () + ", " + dbconn.getDbDriver () +
", " + dbconn.getDrcName () + ", " +
dbconn.getInitialContext ());
dbconn.connect ();
System.out.println ("After dbconn.connect()");
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
} catch (Exception e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
return dbconn;
}
/**
* This method have Response Object to allow you to print some information on the browser.
* Creation date: (9/29/00 4:35:14 PM)
*/
private void execute (String sqltype) throws SQLException{
if (conn != null && !conn.isClosed ()){
sqlStmt = conn.createStatement ();
sqlStmt.executeQuery (getSqlString ());
if (sqltype.equals ("s") || sqltype.equals ("S")){
result = sqlStmt.getResultSet ();
meta = result.getMetaData ();
}
}
}
/**
* This method have Response Object to allow you to print some information on the browser.
* Creation date: (9/29/00 4:35:14 PM)
*/
public void execute (String sqlString, String sqlType) throws SQLException{
this.sqlString = sqlString;
execute (sqlType);
}
/**
* Insert the method's description here.
* Creation date: (10/6/00 4:04:06 PM)
* @return java.sql.Connection
*/
public java.sql.Connection getConn (){
return conn;
}
/**
* return the driver of db
* Creation date: (9/29/00 4:29:45 PM)
* @return java.lang.String
*/
public java.lang.String getDbDriver (){
return dbDriver;
}
/**
* return the password of db
* Creation date: (9/29/00 4:29:25 PM)
* @return java.lang.String
*/
public java.lang.String getDbPassword (){
return dbPassword;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:34:01 PM)
* @return java.lang.String
*/
public java.lang.String getDbURL (){
return dbURL;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:29:04 PM)
* @return java.lang.String
*/
public java.lang.String getDbUserID (){
return dbUserID;
}
/**
* Insert the method's description here.
* Creation date: (7/17/2002 12:17:51 PM)
* @return java.lang.String
*/
public java.lang.String getDrcName (){
return drcName;
}
/**
* Insert the method's description here.
* Creation date: (10/8/02 10:07:36 AM)
* @return java.lang.String
*/
public java.lang.String getInitialContext (){
return initialContext;
}
/**
* Insert the method's description here.
* Creation date: (10/2/00 1:35:04 PM)
* @return java.sql.ResultSetMetaData
*/
public java.sql.ResultSetMetaData getMeta (){
return meta;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 5:05:13 PM)
* @return java.sql.ResultSet
*/
public java.sql.ResultSet getResult (){
return result;
}
/**
* Insert the method's description here.
* Creation date: (10/6/00 4:06:40 PM)
* @return java.sql.Statement
*/
public java.sql.Statement getSqlStmt (){
return sqlStmt;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:55:48 PM)
* @return java.lang.String
*/
public java.lang.String getSqlString (){
return sqlString;
}
/**
* Insert the method's description here.
* Creation date: (7/18/02 5:05:30 PM)
*/
public void rollback (){
try{
if (conn != null && !conn.isClosed ()){
conn.rollback ();
}
} catch (SQLException e){
}
}
/**
* Insert the method's description here.
* Creation date: (7/18/02 5:04:34 PM)
* @param autoCommit boolean
*/
public void setAutoCommit (boolean autoCommit){
String methodName = "setAutoCommit()";
try{
if (conn != null && !conn.isClosed ()){
conn.setAutoCommit (autoCommit);
}
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
}
/**
* Insert the method's description here.
* Creation date: (10/6/00 4:04:06 PM)
* @param newConn java.sql.Connection
*/
public void setConn (java.sql.Connection newConn){
conn = newConn;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:29:45 PM)
* @param newDbDriver java.lang.String
*/
public void setDbDriver (java.lang.String newDbDriver){
dbDriver = newDbDriver;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:29:25 PM)
* @param newDbPassword java.lang.String
*/
public void setDbPassword (java.lang.String newDbPassword){
dbPassword = newDbPassword;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:34:01 PM)
* @param newDbURL java.lang.String
*/
public void setDbURL (java.lang.String newDbURL){
dbURL = newDbURL;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:29:04 PM)
* @param newDbUserID java.lang.String
*/
public void setDbUserID (java.lang.String newDbUserID){
dbUserID = newDbUserID;
}
/**
* Insert the method's description here.
* Creation date: (7/17/2002 12:17:51 PM)
* @param newDrcName java.lang.String
*/
public void setDrcName (java.lang.String newDrcName){
drcName = newDrcName;
}
/**
* Insert the method's description here.
* Creation date: (10/8/02 10:07:36 AM)
* @param newInitialContext java.lang.String
*/
public void setInitialContext (java.lang.String newInitialContext){
initialContext = newInitialContext;
}
/**
* Insert the method's description here.
* Creation date: (10/2/00 1:35:04 PM)
* @param newMeta java.sql.ResultSetMetaData
*/
public void setMeta (java.sql.ResultSetMetaData newMeta){
meta = newMeta;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 5:05:13 PM)
* @param newResult java.sql.ResultSet
*/
void setResult (java.sql.ResultSet newResult){
result = newResult;
}
/**
* Insert the method's description here.
* Creation date: (10/6/00 4:06:40 PM)
* @param newSqlStmt java.sql.Statement
*/
public void setSqlStmt (java.sql.Statement newSqlStmt){
sqlStmt = newSqlStmt;
}
/**
* Insert the method's description here.
* Creation date: (9/29/00 4:55:48 PM)
* @param newSqlString java.lang.String
*/
private void setSqlString (java.lang.String newSqlString){
sqlString = newSqlString;
}
public DataSource setupDataSource (){
BasicDataSource ds = new BasicDataSource ();
ds.setDriverClassName (dbDriver);
ds.setUsername (dbUserID);
ds.setPassword (dbPassword);
ds.setUrl (dbURL);
return ds;
}
public boolean registerDriver (String driverName){
return DbUtils.loadDriver (driverName);
}
public static void closeResultSetAndStatement (java.sql.ResultSet rs){
String methodName = "closeResultSetAndStatement(java.sql.ResultSet)";
java.sql.Statement stmt = null;
try{
stmt = rs.getStatement ();
} catch (java.sql.SQLException e){
System.err.println ("com.netstarmacau.sampleorder.util.DbConnection.closeResultSetAndStatement(Resultset) ==> " +
e.getMessage ());
} finally{
closeResultSetAndStatement (stmt, rs);
}
}
public static void closeResultSetAndStatement (java.sql.Statement stmt){
String methodName = "closeResultSetAndStatement(java.sql.Statement)";
java.sql.ResultSet rs = null;
try{
rs = stmt.getResultSet ();
} catch (java.sql.SQLException e){
System.err.println ("com.netstarmacau.sampleorder.util.DbConnection.closeResultSetAndStatement(Resultset) ==> " +
e.getMessage ());
} finally{
closeResultSetAndStatement (stmt, rs);
}
}
public static void closeResultSetAndStatement (java.sql.Statement stmt,
java.sql.ResultSet rs){
String methodName =
"closeResultSetAndStatement(java.sql.Statement, ava.sql.ResultSet)";
closeResultSet (rs);
closeStatement (stmt);
}
public static void closeStatement (java.sql.Statement stmt){
DbUtils.closeQuietly (stmt);
}
public static void closeResultSet (java.sql.ResultSet rs){
DbUtils.closeQuietly (rs);
}
public static void closeConnection (Connection conn){
DbUtils.closeQuietly (conn);
}
public static void closeAll (Connection conn, Statement stmt, ResultSet rs){
DbUtils.closeQuietly (conn, stmt, rs);
}
public static void closeAll (DBConnection dbconn, Statement stmt,
ResultSet rs){
if (dbconn != null){
dbconn.close ();
}
closeResultSetAndStatement (stmt, rs);
}
public static void commit (Connection conn){
String methodName = "commit()";
try{
if (conn != null && !conn.isClosed ()){
conn.commit ();
}
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
}
public static void setAutoCommit (Connection conn, boolean autoCommit){
String methodName = "setAutoCommit()";
try{
if (conn != null && !conn.isClosed ()){
conn.setAutoCommit (autoCommit);
}
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
}
public static void rollback (Connection conn){
String methodName = "rollback()";
try{
if (conn != null && !conn.isClosed ()){
conn.rollback ();
}
} catch (SQLException e){
System.out.println (className + "." + methodName + " ==> " +
e.getClass ().getName () + ": " + e.getMessage ());
}
}
public static void closePrePareStatement (java.sql.PreparedStatement pstmt){
DbUtils.closeQuietly (pstmt);
}
}
相关文章推荐
- 发现一个问题,十分蛋疼。 我们项目是由N个工程组成的,外围工程是web工程,内部的工程打包成jar,放入外围工程的WEB-INF/lib 内部的工程用到了spring的注解,例如@Service、
- 公司项目中用到的全国省市的一个折叠效果
- 我们的一个已投产项目的高可用数据库实战 - mongo 副本集的搭建具体过程
- JDBC之实现一个最基本的数据库连接池
- 做一个项目,平时都用到哪些工具提高效率(中)
- 一个项目用到的sql语句
- 无意中看到一个项目,和我们现在做的很相似
- 为什么我们做一个软件项目,就要折腾个一年半载的,客户被折磨得死去活来,我们自己也被折磨得死去活来
- JAVA的JDBC的简单练习项目,一个简单的饭卡系统
- 最近一个项目用到PostgresSQl数据库,有些不同于oracle数据库,尤其时间处理上,结合PostgreSQL手册以及网上转载些资料,如下,方便开发中用到
- 为什么我们做一个软件项目,就要折腾个一年半载的,客户被折磨得死去活来,我们自己也被折磨得死去活来
- 在自己的web项目中添一个连接池
- 做一个项目,平时都用到哪些工具提高效率(下)
- 为什么我们做一个软件项目,就要折腾个一年半载的,客户被折磨得死去活来,我们自己也被折磨得死去活来
- 贴一个项目中用到的.net显示今天农历的代码!
- 项目用到的一个资源管理类
- 在项目中用到datatables比较多,但是当datatables加载超过1000多的时候就会出现有点缓慢的的样子,这个时候如果继续增加数据量让datatables去处理,那会是一个让人抓狂的事情,幸
- 项目中用到的一个简单的流量统计例子-java流量统计
- 做一个项目,平时都用到哪些工具提高效率(上)
- 来,我们讨论一下,对一个具体虚拟的图书馆项目. 以数据库为中心的建模方式是咋样的.