• 1.參見官網(wǎng)上Torque的初始化和配置
• 2.torque.properties配置
• 3.log4j.properties配置
• 4.初始化Torque
• 5.使用

1.參見官網(wǎng)上Torque的初始化和配置

Database handles(數(shù)據(jù)庫句柄)

A database handle is the name attribute that was used in the <database> tag of the schema.xml file. If the name attribute is not used, then the handle would be ‘default’.

In all examples that follow we will use the handle ‘bookstore’. As Torque has the ability to use multiple databases you can tell it which one to use by default thus(由于Torque能夠使用多個數(shù)據(jù)庫，因此可以告訴它默認使用哪個數(shù)據(jù)庫):

torque.database.default=bookstore

The handle name ‘default’ is reserved, as Torque uses it as a reference to the default database. So you should not define the handle ‘default’ yourself (but of course you can use it e.g. in generated code).

Multiple databases

The configuration of multiple databases is very similar to the configurations described in the rest of this section, however you will need to define more than one database handle.
多個數(shù)據(jù)庫的配置與本節(jié)其余部分中描述的配置非常相似，但是需要定義多個數(shù)據(jù)庫句柄。

2.torque.properties配置

配置文件一般放在classes目錄下

# ------------------------------------------------------------------- # $Id: Torque.properties,v 1.11.2.2 2004/08/24 04:14:32 seade Exp $ # # This is the configuration file for Torque. # # Note that strings containing "," (comma) characters must backslash # escape the comma (i.e. '\,') # # -------------------------------------------------------------------torque.applicationRoot = .# ------------------------------------------------------------------- # # L O G G I N G # # ------------------------------------------------------------------- # We use Log4J for all Torque logging and we embed the log4j # properties within our application configuration. # -------------------------------------------------------------------# This first category is required and the category # must be named 'default'. This is used for all logging # where an explicit category is not specified.log4j.category.org.apache.torque = ALL, org.apache.torque log4j.appender.org.apache.torque = org.apache.log4j.FileAppender #log4j.appender.org.apache.torque.file = C:/work/jxc/logs/torque.log log4j.appender.org.apache.torque.layout = org.apache.log4j.PatternLayout log4j.appender.org.apache.torque.layout.conversionPattern = %d [%t] %-5p %c - %m%n log4j.appender.org.apache.torque.append = false# ------------------------------------------------------------------- # # T O R Q U E P R O P E R T I E S # # ------------------------------------------------------------------- # These are your database settings. Look in the # org.apache.torque.pool.* packages for more information. # # The parameters to connect to the default database. You MUST # configure these properly. # -------------------------------------------------------------------torque.database.default=bookstore torque.database.bookstore.adapter=oracle## # Using commons-dbcp #torque.dsfactory.bookstore.factory=org.apache.torque.dsfactory.SharedPoolDataSourceFactory #torque.dsfactory.bookstore.pool.maxIdle=10 #torque.dsfactory.bookstore.pool.maxActive=50 #torque.dsfactory.bookstore.pool.testOnBorrow=true #torque.dsfactory.bookstore.pool.validationQuery=select * from dual #torque.dsfactory.bookstore.connection.driver = oracle.jdbc.driver.OracleDriver #torque.dsfactory.bookstore.connection.url = jdbc:oracle:thin:@192.168.1.100:1521:bookstore #torque.dsfactory.bookstore.connection.user = oracle #torque.dsfactory.bookstore.connection.password = oracle# # Using c3p0 torque.dsfactory.bookstore.factory=org.apache.torque.dsfactory.C3P0DataSourceFactory #<!--當連接池中的連接耗盡的時候c3p0一次同時獲取的連接數(shù)。Default: 3 --> torque.dsfactory.bookstore.pool.acquireIncrement=3 #<!--定義在從數(shù)據(jù)庫獲取新連接失敗后重復(fù)嘗試的次數(shù)。Default: 30 --> torque.dsfactory.bookstore.pool.acquireRetryAttempts=30 #<!--兩次連接中間隔時間，單位毫秒。Default: 1000 --> #torque.dsfactory.bookstore.pool.acquireRetryDelay=1000 #<!--當連接池用完時客戶端調(diào)用getConnection()后等待獲取新連接的時間，超時后將拋出SQLException,如設(shè)為0則無限期等待。 #單位毫秒。Default: 0 --> torque.dsfactory.bookstore.pool.checkoutTimeout=30000 #<!--初始化時獲取三個連接，取值應(yīng)在minPoolSize與maxPoolSize之間。Default: 3 --> torque.dsfactory.bookstore.pool.initialPoolSize=5 #<!--最大空閑時間,60秒內(nèi)未使用則連接被丟棄。若為0則永不丟棄。 #單位：秒 Default: 0 --> torque.dsfactory.bookstore.pool.maxIdleTime=0 #<!--連接池中保留的最大連接數(shù)。Default: 15 --> torque.dsfactory.bookstore.pool.maxPoolSize=50 #<!--JDBC的標準參數(shù)，用以控制數(shù)據(jù)源內(nèi)加載的PreparedStatements數(shù)量。但由于預(yù)緩存的statements #屬于單個connection而不是整個連接池。所以設(shè)置這個參數(shù)需要考慮到多方面的因素。 #如果maxStatements與maxStatementsPerConnection均為0，則緩存被關(guān)閉。Default: 0--> torque.dsfactory.bookstore.pool.maxStatements=150 <!--maxStatementsPerConnection定義了連接池內(nèi)單個連接所擁有的最大緩存statements數(shù)。Default: 0 --> torque.dsfactory.bookstore.pool.maxStatementsPerConnection=0 #<!--c3p0是異步操作的，緩慢的JDBC操作通過幫助進程完成。擴展這些操作可以有效的提升性能 #通過多線程實現(xiàn)多個操作同時被執(zhí)行。Default: 3--> torque.dsfactory.bookstore.pool.numHelperThreads=3 #<!--每60秒檢查所有連接池中的空閑連接。單位：秒 Default: 0 --> torque.dsfactory.bookstore.pool.idleConnectionTestPeriod=600 #<!--定義所有連接測試都執(zhí)行的測試語句。在使用連接測試的情況下這個一顯著提高測試速度。注意： #測試的表必須在初始數(shù)據(jù)源的時候就存在。Default: null--> torque.dsfactory.bookstore.pool.preferredTestQuery=select * from dual #db connnection torque.dsfactory.bookstore.connection.driverClass = oracle.jdbc.driver.OracleDriver torque.dsfactory.bookstore.connection.jdbcUrl = jdbc:oracle:thin:@192.168.1.100:1521:bookstore torque.dsfactory.bookstore.connection.user = oracle torque.dsfactory.bookstore.connection.password = oracle# Determines if the quantity column of the IDBroker's id_table should # be increased automatically if requests for ids reaches a high # volume.torque.idbroker.clever.quantity=false# Determines whether the managers cache instances of the business objects. # And also whether the MethodResultCache will really cache results.torque.manager.useCache = true## 第二個數(shù)據(jù)庫連接 torque.database=order torque.database.order.adapter=oracletorque.dsfactory.order.factory=org.apache.torque.dsfactory.C3P0DataSourceFactory torque.dsfactory.order.pool.acquireIncrement=2 torque.dsfactory.order.pool.acquireRetryAttempts=30 torque.dsfactory.order.pool.checkoutTimeout=30000 torque.dsfactory.order.pool.initialPoolSize=1 torque.dsfactory.order.pool.maxIdleTime=0 torque.dsfactory.order.pool.maxPoolSize=50 torque.dsfactory.order.pool.maxStatements=150 torque.dsfactory.order.pool.maxStatementsPerConnection=0 torque.dsfactory.order.pool.numHelperThreads=3 torque.dsfactory.order.pool.idleConnectionTestPeriod=600 torque.dsfactory.order.pool.preferredTestQuery=select sysdate from dualtorque.dsfactory.order.connection.driverClass = oracle.jdbc.driver.OracleDriver torque.dsfactory.order.connection.jdbcUrl = jdbc:oracle:thin:@192.168.2.200:1521:BABY_ORDER torque.dsfactory.order.connection.user = scott torque.dsfactory.order.connection.password = tiger

3.log4j.properties配置

# ------------------------------------------------------------------------ # # Logging Configuration # # $Id: log4j.properties,v 1.10 2005/07/27 04:25:09 huangxq Exp $ # # ------------------------------------------------------------------------# # If we don't know the logging facility, put it into the # sl.log # log4j.rootLogger = error, root, stdout# # Application debugging # #log4j.category.com.sl = debug, sl log4j.category.com.sl = debug, sl, stdout log4j.additivity.com.sl = false# # torque goes into torque Log # log4j.category.org.apache.torque = debug, torque log4j.additivity.org.apache.torque = false######################################################################## # # Logfile definitions # #########################################################################print out to console log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.layout=org.apache.log4j.PatternLayout log4j.appender.stdout.layout.ConversionPattern=%d [%-5p] [%F] %M : %L -- %m%n# # root.log # log4j.appender.root = org.apache.log4j.DailyRollingFileAppender log4j.appender.root.file = D:/logs/fmanage/fmanage_root.log log4j.appender.root.DatePattern='.'yyyy-MM-dd log4j.appender.root.layout = org.apache.log4j.PatternLayout log4j.appender.root.layout.conversionPattern =%d [%-5p] [%F] : %L -- %m%n log4j.appender.root.append = false# # sl.log # log4j.appender.sl = org.apache.log4j.DailyRollingFileAppender log4j.appender.sl.file = D:/logs/fmanage/fmanage_sl.log log4j.appender.sl.DatePattern='.'yyyy-MM-dd log4j.appender.sl.layout = org.apache.log4j.PatternLayout log4j.appender.sl.layout.conversionPattern =%d [%-5p] [%F] : %L -- %m%n log4j.appender.sl.append = true# # torque.log # log4j.appender.torque = org.apache.log4j.DailyRollingFileAppender log4j.appender.torque.file = D:/logs/fmanage/fmanage_torque.log log4j.appender.torque.DatePattern='.'yyyy-MM-dd log4j.appender.torque.layout = org.apache.log4j.PatternLayout log4j.appender.torque.layout.conversionPattern =%d [%-5p] [%F] : %L -- %m%n log4j.appender.torque.append = false

4.初始化Torque

InitServer.java

package com.sl;import java.io.InputStream; import java.util.List; import java.util.Properties; import org.apache.commons.configuration.PropertiesConfiguration; import org.apache.log4j.Logger; import org.apache.log4j.PropertyConfigurator; import com.sl.util.DBUtils; import com.workingdogs.village.Record;public class InitServer {private static Logger log;private static final String TORQUE_CONFIG_FILE = "torque.properties";private static final String LOG4J_CONFIG_FILE = "log4j.properties";public static boolean init() {// 初始化boolean flag = true;ClassLoader cl = InitServer.class.getClassLoader();InputStream logIn = null;InputStream dbIn = null;try {logIn = cl.getResourceAsStream(LOG4J_CONFIG_FILE);Properties p = new Properties();p.load(logIn);PropertyConfigurator.configure(p);log = Logger.getLogger(InitServer.class);log.debug("InitServer init() log4j init success ---------------");// 初始化PropertiesConfiguration dbConfig = new PropertiesConfiguration();dbIn = cl.getResourceAsStream(TORQUE_CONFIG_FILE);dbConfig.load(dbIn);DBUtils.init(dbConfig);log.debug("InitServer init() Torque init success ---------------");String testSql = "select to_char(sysdate,'YYYY-MM-DD HH24:MI:SS') from dual";String time = null;List<Record> list = DBUtils.query(testSql);if (list != null && list.size() > 0) {Record record = list.get(0);time = record.getValue(1).asString();log.debug("from db init-time: " + time);}} catch (Exception ex) {log.error("InitServer Exception when init() - " + ex);flag = false;} finally {closeInputStream(logIn);closeInputStream(dbIn);}return flag;}private static void closeInputStream(InputStream is) {// 退出前,一定要將文件處理讀寫器關(guān)閉try {if (is != null)is.close();is = null;} catch (Exception exx) {log.error(exx);}}}

DBUtils.java

package com.sl.util;import java.sql.Connection; import java.sql.ResultSet; import java.sql.Statement; import java.util.List; import org.apache.commons.configuration.Configuration; import org.apache.log4j.Logger; import org.apache.torque.util.BasePeer; import com.workingdogs.village.Record; import org.apache.torque.Torque;public class DBUtils {private static Logger log = Logger.getLogger(DBUtils.class.getName());public DBUtils() {}/*** 初始化* * @param dbConfigFile* @return*/public static boolean init(String dbConfigFile) {// 初始化torqueboolean flag = true;try {Torque.init(dbConfigFile);System.out.println("---------- 初始化torque成功---------");} catch (Exception exx) {log.error(exx);flag = false;}return flag;}/*** 初始化* * @param dbConfig* @return*/public static boolean init(Configuration dbConfig) {// 初始化torqueboolean flag = true;try {Torque.init(dbConfig);System.out.println("---------- 初始化torque成功---------");} catch (Exception exx) {log.error(exx);flag = false;}return flag;}/*** 獲取數(shù)據(jù)庫連接(默認)* * @return*/public static Connection getDBConn() {// 取得數(shù)據(jù)庫連接Connection conn = null;try {conn = Torque.getConnection();} catch (Exception exx) {log.error(exx);}return conn;}/*** 獲取指定數(shù)據(jù)庫連接* * @param dbName* @return*/public static Connection getDBConn(String dbName) {// 取得數(shù)據(jù)庫連接Connection conn = null;try {conn = Torque.getConnection(dbName);} catch (Exception exx) {log.error(exx);}return conn;}/*** 獲取默認數(shù)據(jù)庫連接，是否支持事務(wù)自動提交* * @param autoCommitFlag* @return*/public static Connection getDBConn(boolean autoCommitFlag) {// 取得數(shù)據(jù)庫連接Connection conn = null;try {conn = Torque.getConnection();setAutoCommit(conn, autoCommitFlag);} catch (Exception exx) {log.error(exx);}return conn;}/*** 獲取指定數(shù)據(jù)庫連接，是否支持事務(wù)自動提交* * @param dbName* @param autoCommitFlag* @return*/public static Connection getDBConn(String dbName, boolean autoCommitFlag) {// 取得數(shù)據(jù)庫連接Connection conn = null;try {conn = Torque.getConnection(dbName);setAutoCommit(conn, autoCommitFlag);} catch (Exception exx) {log.error(exx);}return conn;}/*** 關(guān)閉數(shù)據(jù)庫連接* * @param conn*/public static void closeDBConn(Connection conn) {// 關(guān)閉數(shù)據(jù)庫連接try {if (conn != null) {setAutoCommit(conn, true);// 無論如何，都應(yīng)該在連接關(guān)閉前，將AutoCommit 設(shè)置為// trueTorque.closeConnection(conn);conn = null;}} catch (Exception exx) {log.error(exx);}}/*** 關(guān)閉Statement* * @param statement*/public static void closeDBStatement(Statement statement) {// 關(guān)閉Statementtry {if (statement != null) {statement.close();statement = null;}} catch (Exception exx) {log.error(exx);}}/*** 關(guān)閉Statement,關(guān)閉數(shù)據(jù)庫連接* * @param statement* @param conn*/public static void closeDBObject(Statement statement, Connection conn) {// 關(guān)閉StatementcloseDBStatement(statement);// 關(guān)閉數(shù)據(jù)庫連接closeDBConn(conn);}/*** 關(guān)閉ResultSet* * @param resultSet*/public static void closeDBResultSet(ResultSet resultSet) {// 關(guān)閉ResultSettry {if (resultSet != null) {resultSet.close();resultSet = null;}} catch (Exception exx) {log.error(exx);}}/*** 關(guān)閉Statement,關(guān)閉ResultSet,關(guān)閉數(shù)據(jù)庫連接* * @param statement* @param resultSet* @param conn* @param autoCommitFlag*/public static void closeDBObject(Statement statement, ResultSet resultSet, Connection conn) {// 關(guān)閉StatementcloseDBStatement(statement);// 關(guān)閉ResultSetcloseDBResultSet(resultSet);// 關(guān)閉數(shù)據(jù)庫鏈接closeDBConn(conn);}/*** 提交事務(wù)* * @param conn*/public static void commit(Connection conn) {try {if (conn != null) {if (conn.getMetaData().supportsTransactions() && conn.getAutoCommit() == false) {conn.commit();conn.setAutoCommit(true);}}} catch (Exception exx) {log.error(exx);}}/*** 回滾事務(wù)* * @param conn*/public static void rollback(Connection conn) {try {if (conn != null) {if (conn.getMetaData().supportsTransactions() && conn.getAutoCommit() == false) {conn.rollback();conn.setAutoCommit(true);}}} catch (Exception ee) {log.error(ee);}}/*** 設(shè)置是否自動提交事務(wù)* * @param conn* @param autoCommitFlag*/public static void setAutoCommit(Connection conn, boolean autoCommitFlag) {try {if (conn.getMetaData().supportsTransactions()) {conn.setAutoCommit(autoCommitFlag);}} catch (Exception e) {log.error(e);}}/*** 查詢返回所有記錄* * @param querySql* @return*/@SuppressWarnings("unchecked")public static List<Record> query(String querySql) {List<Record> results = null;try {results = BasePeer.executeQuery(querySql);} catch (Exception ee) {results = null;log.error(ee);}return results;}/*** 查詢 * singleRecord = true 表示只返回一條記錄 * singleRecord = false 表示返回所有記錄* * @param conn* @param singleRecord* @param querySql* @return*/@SuppressWarnings("unchecked")public static List<Record> query(Connection conn, boolean singleRecord, String querySql) {List<Record> results = null;try {if (conn != null) {results = BasePeer.executeQuery(querySql, singleRecord, conn);}} catch (Exception ee) {results = null;log.error(ee);} finally {closeDBConn(conn);}return results;}/*** 查詢返回所有記錄* * @param conn* @param querySql* @return*/public static List<Record> query(Connection conn, String querySql) {List<Record> results = null;boolean singleRecord = false;results = query(conn, singleRecord, querySql);return results;}/*** 查詢指定配置的數(shù)據(jù)庫,返回所有記錄* * @param dbName* @param querySql* @return*/public static List<Record> query(String dbName, String querySql) {List<Record> results = null;try {Connection conn = DBUtils.getDBConn(dbName);if (conn != null) {results = query(conn, querySql);}} catch (Exception ee) {results = null;log.error(ee);}return results;}/*** 添加或更新數(shù)據(jù)庫記錄* * @param insertOrUpdateSql* @return*/public static int insertOrUpdate(String insertOrUpdateSql) {int results = -1;try {results = BasePeer.executeStatement(insertOrUpdateSql);} catch (Exception ee) {results = -1;log.error(ee);}return results;}/*** 添加或更新數(shù)據(jù)庫記錄* * @param conn* @param insertOrUpdateSql* @return*/public static int insertOrUpdate(Connection conn, String insertOrUpdateSql) {int results = -1;try {if (conn != null) {results = BasePeer.executeStatement(insertOrUpdateSql, conn);}} catch (Exception ee) {results = -1;log.error(ee);} finally {closeDBConn(conn);}return results;}}

5.使用

查詢默認數(shù)據(jù)庫可直接使用List<Record> list = DBUtils.query(querySql);
也可以List<Record> list = DBUtils.query("bookstore", querySql);

查詢指定的數(shù)據(jù)庫使用List<Record> list = DBUtils.query("order", querySql);

注：“order”是自定義的數(shù)據(jù)庫名，可以和真實數(shù)據(jù)庫名不一樣，作為Torque的數(shù)據(jù)庫標識。

本文參考:
http://www.blogjava.net/fanyingjie/archive/2008/05/22/202114.html

總結(jié)

以上是生活随笔為你收集整理的Apache Torque连接多个数据库及其使用的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。