您的位置:首页 > 其它

使用BoneCP的必备条件

2013-04-26 17:13 399 查看
使用BoneCP需要如下类库支持:

被连接的数据库的JDBC驱动程序,这个可以到该数据库厂商网站下载;

Google的集合框架Guava,它的网址是:http://code.google.com/p/guava-libraries/,这个需要说明的是BoneCP官方网站说的必备框架是Google Collect框架,但是这个框架已经不再支持了,而是转为新的集合框架Guava;

SLF4J日志类库(在早期的BoneCP版本中直接使用了Log4J类库);

JDK1.5及更高版本。

下面是测试项目中的类库截图:

也就是需要了如下Jar包:

bonecp-0.7.0.jar

mysql-connector-java-5.1.13-bin.jar

slf4j-log4j12-1.6.1.jar

slf4j-api-1.6.1.jar

log4j-1.2.16.jar

guava-r07.jar

为了得到比较详细的运行过程信息,需要添加一个log4j的配置文件log4j.properties,log4j.properties的文件位置如上图,文件内容如下:

view plaincopy to clipboardprint?

01.#log4j.rootLogger=DEBUG,CONSOLE,A1,im

02.log4j.rootLogger=DEBUG,CONSOLE

03.log4j.addivity.org.apache=true

04.# 应用于控制台

05.log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender

06.log4j.appender.Threshold=DEBUG

07.log4j.appender.CONSOLE.Target=System.out

08.log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout

09.log4j.appender.CONSOLE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n

10.#log4j.appender.CONSOLE.layout.ConversionPattern=[start]%d{DATE}[DATE]%n%p[PRIORITY]%n%x[NDC]%n%t[THREAD] n%c[CATEGORY]%n%m[MESSAGE]%n%n

11.#应用于文件

12.#log4j.appender.FILE=org.apache.log4j.FileAppender

13.#log4j.appender.FILE.File=file.log

14.#log4j.appender.FILE.Append=false

15.#log4j.appender.FILE.layout=org.apache.log4j.PatternLayout

16.#log4j.appender.FILE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n

17.# Use this layout for LogFactor 5 analysis

18.# 应用于文件回滚

19.# log4j.appender.ROLLING_FILE=org.apache.log4j.RollingFileAppender

20.# log4j.appender.ROLLING_FILE.Threshold=ERROR

21.# log4j.appender.ROLLING_FILE.File=rolling.log //????,??????${java.home}?rolling.log

22.# log4j.appender.ROLLING_FILE.Append=true //true/:?? false/:??

23.# log4j.appender.ROLLING_FILE.MaxFileSize=10KB //??????

24.# log4j.appender.ROLLING_FILE.MaxBackupIndex=1 //???

25.# log4j.appender.ROLLING_FILE.layout=org.apache.log4j.PatternLayout

26.# log4j.appender.ROLLING_FILE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n

27.#应用于socket

28.#log4j.appender.SOCKET=org.apache.log4j.RollingFileAppender

29.#log4j.appender.SOCKET.RemoteHost=localhost

30.#log4j.appender.SOCKET.Port=5001

31.#log4j.appender.SOCKET.LocationInfo=true

32.# Set up for Log Facter 5

33.#log4j.appender.SOCKET.layout=org.apache.log4j.PatternLayout

34.#log4j.appender.SOCET.layout.ConversionPattern=[start]%d{DATE}[DATE]%n%p[PRIORITY]%n%x[NDC]%n%t[THREAD]%n%c[CATEGORY]%n%m[MESSAGE]%n%n

35.# Log Factor 5 Appender

36.#log4j.appender.LF5_APPENDER=org.apache.log4j.lf5.LF5Appender

37.#log4j.appender.LF5_APPENDER.MaxNumberOfRecords=2000

38.# 发送日志给邮件

39.#log4j.appender.MAIL=org.apache.log4j.net.SMTPAppender

40.#log4j.appender.MAIL.Threshold=FATAL

41.#log4j.appender.MAIL.BufferSize=10

42.

43.#[email=log4j.appender.MAIL.To/=web@www.wusetu.com]log4j.appender.MAIL.To/=web@www.wusetu.com[/email]

44.

45.#log4j.appender.MAIL.SMTPHost=www.wusetu.com

46.#log4j.appender.MAIL.Subject=Log4J Message

47.

48.#log4j.appender.MAIL.layout=org.apache.log4j.PatternLayout

49.#log4j.appender.MAIL.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n

50.# 用于数据库

51.log4j.appender.DATABASE=org.apache.log4j.jdbc.JDBCAppender

52.log4j.appender.DATABASE.URL=jdbc:mysql://localhost:3306/test

53.log4j.appender.DATABASE.driver=com.mysql.jdbc.Driver

54.log4j.appender.DATABASE.user=root

55.log4j.appender.DATABASE.password=jeri

56.log4j.appender.DATABASE.sql=INSERT INTO LOG4J (Message) VALUES ('[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n')

57.log4j.appender.DATABASE.layout=org.apache.log4j.PatternLayout

58.log4j.appender.DATABASE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n

59.#log4j.appender.A1=org.apache.log4j.DailyRollingFileAppender

60.#log4j.appender.A1.File=SampleMessages.log4j

61.#log4j.appender.A1.DatePattern=yyyyMMdd-HH'.log4j'

62.#log4j.appender.A1.layout=org.apache.log4j.xml.XMLLayout

63.#自定义Appender

64.#log4j.appender.im = net.cybercorlin.util.logger.appender.IMAppender

65.#log4j.appender.im.host = mail.cybercorlin.net

66.#log4j.appender.im.username = username

67.#log4j.appender.im.password = password

68.#log4j.appender.im.recipient = corlin@cybercorlin.net

69.

70.#log4j.appender.im.layout=org.apache.log4j.PatternLayout

71.#log4j.appender.im.layout.ConversionPattern =[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n

#log4j.rootLogger=DEBUG,CONSOLE,A1,im

log4j.rootLogger=DEBUG,CONSOLE

log4j.addivity.org.apache=true

# 应用于控制台

log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender

log4j.appender.Threshold=DEBUG

log4j.appender.CONSOLE.Target=System.out

log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout

log4j.appender.CONSOLE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n

#log4j.appender.CONSOLE.layout.ConversionPattern=[start]%d{DATE}[DATE]%n%p[PRIORITY]%n%x[NDC]%n%t[THREAD] n%c[CATEGORY]%n%m[MESSAGE]%n%n

#应用于文件

#log4j.appender.FILE=org.apache.log4j.FileAppender

#log4j.appender.FILE.File=file.log

#log4j.appender.FILE.Append=false

#log4j.appender.FILE.layout=org.apache.log4j.PatternLayout

#log4j.appender.FILE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n

# Use this layout for LogFactor 5 analysis

# 应用于文件回滚

# log4j.appender.ROLLING_FILE=org.apache.log4j.RollingFileAppender

# log4j.appender.ROLLING_FILE.Threshold=ERROR

# log4j.appender.ROLLING_FILE.File=rolling.log //????,??????${java.home}?rolling.log

# log4j.appender.ROLLING_FILE.Append=true //true/:?? false/:??

# log4j.appender.ROLLING_FILE.MaxFileSize=10KB //??????

# log4j.appender.ROLLING_FILE.MaxBackupIndex=1 //???

# log4j.appender.ROLLING_FILE.layout=org.apache.log4j.PatternLayout

# log4j.appender.ROLLING_FILE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n

#应用于socket

#log4j.appender.SOCKET=org.apache.log4j.RollingFileAppender

#log4j.appender.SOCKET.RemoteHost=localhost

#log4j.appender.SOCKET.Port=5001

#log4j.appender.SOCKET.LocationInfo=true

# Set up for Log Facter 5

#log4j.appender.SOCKET.layout=org.apache.log4j.PatternLayout

#log4j.appender.SOCET.layout.ConversionPattern=[start]%d{DATE}[DATE]%n%p[PRIORITY]%n%x[NDC]%n%t[THREAD]%n%c[CATEGORY]%n%m[MESSAGE]%n%n

# Log Factor 5 Appender

#log4j.appender.LF5_APPENDER=org.apache.log4j.lf5.LF5Appender

#log4j.appender.LF5_APPENDER.MaxNumberOfRecords=2000

# 发送日志给邮件

#log4j.appender.MAIL=org.apache.log4j.net.SMTPAppender

#log4j.appender.MAIL.Threshold=FATAL

#log4j.appender.MAIL.BufferSize=10

#[email=log4j.appender.MAIL.To/=web@www.wusetu.com]log4j.appender.MAIL.To/=web@www.wusetu.com[/email]

#log4j.appender.MAIL.SMTPHost=www.wusetu.com

#log4j.appender.MAIL.Subject=Log4J Message

#log4j.appender.MAIL.layout=org.apache.log4j.PatternLayout

#log4j.appender.MAIL.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n

# 用于数据库

log4j.appender.DATABASE=org.apache.log4j.jdbc.JDBCAppender

log4j.appender.DATABASE.URL=jdbc:mysql://localhost:3306/test

log4j.appender.DATABASE.driver=com.mysql.jdbc.Driver

log4j.appender.DATABASE.user=root

log4j.appender.DATABASE.password=jeri

log4j.appender.DATABASE.sql=INSERT INTO LOG4J (Message) VALUES ('[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n')

log4j.appender.DATABASE.layout=org.apache.log4j.PatternLayout

log4j.appender.DATABASE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n

#log4j.appender.A1=org.apache.log4j.DailyRollingFileAppender

#log4j.appender.A1.File=SampleMessages.log4j

#log4j.appender.A1.DatePattern=yyyyMMdd-HH'.log4j'

#log4j.appender.A1.layout=org.apache.log4j.xml.XMLLayout

#自定义Appender

#log4j.appender.im = net.cybercorlin.util.logger.appender.IMAppender

#log4j.appender.im.host = mail.cybercorlin.net

#log4j.appender.im.username = username

#log4j.appender.im.password = password

#log4j.appender.im.recipient = corlin@cybercorlin.net

#log4j.appender.im.layout=org.apache.log4j.PatternLayout

#log4j.appender.im.layout.ConversionPattern =[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n

在JDBC中使用BoneCP

在JDBC中使用BoneCP相当简单,设置一些关于数据库连接池的参数信息,比如连接池的最大、最小连接数等。下面是一个简单的例子:

package com.netskycn;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import com.jolbox.bonecp.BoneCP;

import com.jolbox.bonecp.BoneCPConfig;

/** 测试bonecp数据库连接池的工具

* @author zhoufoxcn 周公

* @version 0.1

* 说明:这是一个在JDBC中使用BoneCP的例子

* 2010-11-23

*/

public class MainClass {

public static void main(String[] args) {

BoneCP connectionPool = null;

Connection connection = null;

try {

//加载JDBC驱动

Class.forName("com.mysql.jdbc.Driver");

} catch (Exception e) {

e.printStackTrace();

return;

}

try {

//设置连接池配置信息

BoneCPConfig config = new BoneCPConfig();

//数据库的JDBC URL

config.setJdbcUrl("jdbc:mysql:///jobeet");

//数据库用户名

config.setUsername("root");

//数据库用户密码

config.setPassword("jeri");

//数据库连接池的最小连接数

config.setMinConnectionsPerPartition(5);

//数据库连接池的最大连接数

config.setMaxConnectionsPerPartition(10);

//

config.setPartitionCount(1);

//设置数据库连接池

connectionPool = new BoneCP(config);

//从数据库连接池获取一个数据库连接

connection = connectionPool.getConnection(); // fetch a connection

if (connection != null){

System.out.println("Connection successful!");

Statement stmt = connection.createStatement();

ResultSet rs = stmt.executeQuery("SELECT * FROM customer");

while(rs.next()){

System.out.println(rs.getInt(1)+":"+rs.getString("firstname")+","+rs.getString("lastname"));

}

}

//关闭数据库连接池

connectionPool.shutdown();

} catch (SQLException e) {

e.printStackTrace();

} finally {

if (connection != null) {

try {

connection.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

}

}

}

package com.netskycn;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import com.jolbox.bonecp.BoneCP;

import com.jolbox.bonecp.BoneCPConfig;

/** 测试bonecp数据库连接池的工具

* @author zhoufoxcn 周公

* @version 0.1

* 说明:这是一个在JDBC中使用BoneCP的例子

* 2010-11-23

*/

public class MainClass {

public static void main(String[] args) {

BoneCP connectionPool = null;

Connection connection = null;

try {

//加载JDBC驱动

Class.forName("com.mysql.jdbc.Driver");

} catch (Exception e) {

e.printStackTrace();

return;

}

try {

//设置连接池配置信息

BoneCPConfig config = new BoneCPConfig();

//数据库的JDBC URL

config.setJdbcUrl("jdbc:mysql:///jobeet");

//数据库用户名

config.setUsername("root");

//数据库用户密码

config.setPassword("jeri");

//数据库连接池的最小连接数

config.setMinConnectionsPerPartition(5);

//数据库连接池的最大连接数

config.setMaxConnectionsPerPartition(10);

//

config.setPartitionCount(1);

//设置数据库连接池

connectionPool = new BoneCP(config);

//从数据库连接池获取一个数据库连接

connection = connectionPool.getConnection(); // fetch a connection

if (connection != null){

System.out.println("Connection successful!");

Statement stmt = connection.createStatement();

ResultSet rs = stmt.executeQuery("SELECT * FROM customer");

while(rs.next()){

System.out.println(rs.getInt(1)+":"+rs.getString("firstname")+","+rs.getString("lastname"));

}

}

//关闭数据库连接池

connectionPool.shutdown();

} catch (SQLException e) {

e.printStackTrace();

} finally {

if (connection != null) {

try {

connection.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

}

}

}

这个例子相当简单,但是是利用BoneCP提供的连接池而不是直接使用JDBC来管理连接的。

使用DataSource

使用DataSource的话,代码如下:

//加载数据库驱动

Class.forName("com.mysql.jdbc.Driver");

//创建一个DataSource对象

BoneCPDataSource ds = new BoneCPDataSource();

//设置JDBC URL

ds.setJdbcUrl("jdbc:mysql:///jobeet");

//设置用户名

ds.setUsername("sa");

//设置密码

ds.setPassword("jeri");

//下面的代码是设置其它可选属性

//ds.setXXXX(...);

Connection connection;

connection = ds.getConnection();

//这里操作数据库

//...

//关闭数据库连接

connection.close();

ds.close();

//加载数据库驱动

Class.forName("com.mysql.jdbc.Driver");

//创建一个DataSource对象

BoneCPDataSource ds = new BoneCPDataSource();

//设置JDBC URL

ds.setJdbcUrl("jdbc:mysql:///jobeet");

//设置用户名

ds.setUsername("sa");

//设置密码

ds.setPassword("jeri");

//下面的代码是设置其它可选属性

//ds.setXXXX(...);

Connection connection;

connection = ds.getConnection();

//这里操作数据库

//...

//关闭数据库连接

connection.close();

ds.close();

在Hibernate中使用BoneCP

在Hibernate中使用BoneCP除了需要上面提到的jar包之外,还需要下载一个名为bonecp-provider-0.7.0.jar的bonecp-provider的jar包,它的下载位置是:http://jolbox.com/bonecp/downloads/maven/com/jolbox/bonecp-provider/0.7.0/bonecp-provider-0.7.0.jar。

除此之外,还需要做如下配置:

<!-- Hibernate SessionFactory -->

<bean id="sessionFactory" class="org.springframework.orm.hibernate.LocalSessionFactoryBean" autowire="autodetect">

<property name="hibernateProperties">

<props>

<prop key="hibernate.connection.provider_class">com.jolbox.bonecp.provider.BoneCPConnectionProvider</prop>

<prop key="hibernate.connection.driver_class">com.mysql.jdbc.Driver</prop>

<prop key="hibernate.connection.url">jdbc:mysql://127.0.0.1/yourdb</prop>

<prop key="hibernate.connection.username">root</prop>

<prop key="hibernate.connection.password">abcdefgh</prop>

<prop key="bonecp.idleMaxAge">240</prop>

<prop key="bonecp.idleConnectionTestPeriod">60</prop>

<prop key="bonecp.partitionCount">3</prop>

<prop key="bonecp.acquireIncrement">10</prop>

<prop key="bonecp.maxConnectionsPerPartition">60</prop>

<prop key="bonecp.minConnectionsPerPartition">20</prop>

<prop key="bonecp.statementsCacheSize">50</prop>

<prop key="bonecp.releaseHelperThreads">3</prop>

</props>

</property>

</bean>
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: