Java connection database tool class

Package spider.tools;

Import java.sql. *;

Public class dbtools {

Public static final int oracle = 0; public static final int SQLServer = 1;

Private static string oracleDriver = "Oracle.jdbc.driver.Oracledriver"; private static string sqlserdriver = "com.microsoft.jdbc.sqlserver.sqlserdriver";

Public Connection CreateConnection (String Host, String Database, String User, String Password, INT DBKIND) {Connection Result = NULL

String dburl = null; string dbdriver = NULL;

if (dbKind == ORACLE) {dbUrl = createOracleUrl (host, dataBase); dbDriver = oracleDriver;} else if (dbKind == SQLSERVER) {dbUrl = createSqlserverUrl (host, dataBase); dbDriver = sqlserverDriver;} else {MyUtil.log ("Initial Database Connection Failure:" "Unsupport Data Base!"); Return Null;}

try {Class.forName (dbDriver); result = DriverManager.getConnection (dbUrl, user, password);} catch (Exception e) {MyUtil.log ( "initial database connection failure:" e.toString ()); return null } Return result;}

Public String CreateOracleurl (String Host, String Database) {String Oracleurl = "JDBC: Oracle: Thin: @" Host ": 1521:" Database; Return Oracle;

public String createSqlserverUrl (String host, String dataBase) {String sqlServerUrl = "jdbc: microsoft: sqlserver: //" host ": 1433; DatabaseName =" dataBase; return sqlServerUrl;} public boolean isTableExist (Connection cnn, String table ) {Bolean result = false; string strsql = "select * from sysobjects where id = Object_ID ('" Table ")"; statement st = null; resultset = null; try {st = cnn.createstatement (); Rs = st.executeQuery (strsql); = true;} catch (sqlexception ex) {MyUtil.log ("Error Happen When Check Table Existance! Table Name: Table);} Finally {If (st! = Null) {Try {st.close ();} catch (sqlexception ex1) {}}}}}} f = null) {r r rclose ();} catch (sqlexception ex1) {} }}}} Public boolean cleartable (connection cn, string table) {if (! Istableexist (cnn, Table)) Return False; Boolean Flag = true; preparedStatement PS = null; try {ps = cnn.preparestatement ("delete from" table); ps.executeUpdate ();} catch (exception e) {flag = false;} Finally {if (ps! = null) {Try {ps.close ();} catch (sqlexception ex) {}}}}}}}

}