當(dāng)前位置：首頁 >

Apache Torque连接多个数据库及其使用

發(fā)布時間：2024/1/1 43 豆豆

生活随笔收集整理的這篇文章主要介紹了 Apache Torque连接多个数据库及其使用小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.

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ù)庫，因此可以告訴它默認(rèn)使用哪個數(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 # torque.dsfactory.bookstore.pool.acquireIncrement=3 # torque.dsfactory.bookstore.pool.acquireRetryAttempts=30 # #torque.dsfactory.bookstore.pool.acquireRetryDelay=1000 # torque.dsfactory.bookstore.pool.checkoutTimeout=30000 # torque.dsfactory.bookstore.pool.initialPoolSize=5 # torque.dsfactory.bookstore.pool.maxIdleTime=0 # torque.dsfactory.bookstore.pool.maxPoolSize=50 # torque.dsfactory.bookstore.pool.maxStatements=150  torque.dsfactory.bookstore.pool.maxStatementsPerConnection=0 # torque.dsfactory.bookstore.pool.numHelperThreads=3 # torque.dsfactory.bookstore.pool.idleConnectionTestPeriod=600 # 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ù)庫連接(默認(rèn))* * @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;}/*** 獲取默認(rèn)數(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.使用

查詢默認(rèn)數(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ù)庫標(biāo)識。

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

總結(jié)

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

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

上一篇：二年级上册计算题_2015年二年级上册数
下一篇： java计算机毕业设计家电售后管理系统演