中文字幕日韩精品一区二区免费_精品一区二区三区国产精品无卡在_国精品无码专区一区二区三区_国产αv三级中文在线

java數(shù)據(jù)庫連接池代碼 java druid數(shù)據(jù)庫連接池

請問那位可以給個用純java實現(xiàn)數(shù)據(jù)庫連接池的代碼

DataSource ds=null;

網(wǎng)站建設哪家好,找創(chuàng)新互聯(lián)公司!專注于網(wǎng)頁設計、網(wǎng)站建設、微信開發(fā)、微信小程序開發(fā)、集團企業(yè)網(wǎng)站建設等服務項目。為回饋新老客戶創(chuàng)新互聯(lián)還提供了清水免費建站歡迎大家使用!

Connection con=null;

PreparedStatement ps=null;

ResultSet rs=null;

String username=null;

try{

//實現(xiàn)數(shù)據(jù)連接池

Context ctx=new InitialContext();

ds=(DataSource)ctx.lookup("java:comp/env/jdbc/userInfo");

}catch(NamingException ne){ne.printStackTrace();}

try{

con=ds.getConnection();

String sql="select * from guestbook order by gst_time desc";

st=con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,

ResultSet.CONCUR_READ_ONLY);

rs=st.executeQuery(sql);

。。。。。。

。。。

}

在這段代碼中

Context ctx=new InitialContext();

ds=(DataSource)ctx.lookup("java:comp/env/jdbc/userInfo");就是連接池代碼。

它是讀取配置文件(Context.xml)中數(shù)據(jù)的。

以下是配置文件:

Context path="/WebModule1" docBase="E:\Home\WebModule1" reloadable="true"

Resource name="jdbc/userInfo" auth="Container" type="javax.sql.DataSource"

maxActive="100" maxIdle="30" maxWait="10000" username="sa" password="bye0406"

driverClassName="com.microsoft.jdbc.sqlserver.SQLServerDriver"

url="jdbc:microsoft:sqlserver://localhost:1433;databasename=userInfo" /

/Context

path和docBase中的路徑根據(jù)自己需要配置路徑。該路徑是WEB應用程序的路徑。driverClassName和url是連接數(shù)據(jù)庫的驅(qū)動類和連接的URL,是根據(jù)你使用的哪種數(shù)據(jù)庫而定。

以下是四種數(shù)據(jù)庫的配制驅(qū)動:

驅(qū)動

SQL Server 2000

類名:com.microsoft.jdbc.sqlserver.SQLServerDriver

URL:jdbc:microsoft:sqlserver://localhost:1433;databasename=pubs

Oracle

類名:oracle.jdbc.driver.OracleDriver

URL:jdbc:oracle:thin:@localhost:152:ORCL

Mysql

類名:com.mysql.jdbc.Driver

URL:jdbc:mysql://localhost:3306/databasename

JDBC-ODBC

類名:sun.jdbc.odbc.JdbcOdbcDriver

URL:jdbc:odbc:datasource_name;

怎么在JAVA中創(chuàng)建一個數(shù)據(jù)庫連接池?求實例代碼

用c3po來創(chuàng)建數(shù)據(jù)庫連接池,

1.到網(wǎng)絡上下載c3p0-0.9.0.4.jar包,導入工程;(注意以下方法只能用于web服務).

2.找出web服務器中conf目錄下的centent.xml,在里面加上以下配置

Resource auth="Container"

description="DB Connection"

driverClass="com.mysql.jdbc.Driver"

maxPoolSize="4"

minPoolSize="2"

acquireIncrement="1"

name="jdbc/TestDB"

user="root"

password="root"

factory="org.apache.naming.factory.BeanFactory"

type="com.mchange.v2.c3p0.ComboPooledDataSource"

jdbcUrl="jdbc:mysql://localhost:3306/自己的數(shù)據(jù)庫名?autoReconnect=true" /

3.java獲取連接池的代碼;

import java.sql.Connection;

import java.sql.SQLException;

import javax.naming.InitialContext;

import javax.naming.NamingException;

import javax.sql.DataSource;

public class DBUtils {

static InitialContext ic;

static DataSource ds;

static{

try {

ic = new InitialContext();

ds = (DataSource)ic.lookup("java:comp/env/jdbc/TestDB");

} catch (NamingException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

public static Connection getCon() {

try {

return ds.getConnection();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

return null;

}

}

}

通過以上代碼,即可獲取連接池中的連接.

Java開發(fā)常用的幾個數(shù)據(jù)庫連接池

數(shù)據(jù)庫連接池的好處是不言而喻的,現(xiàn)在大部分的application

server都提供自己的數(shù)據(jù)庫連接池方案,此時,只要按照application server的文檔說明,正確配置,即可在應用中享受到數(shù)據(jù)庫連接池的好處。

但是,有些時候,我們的應用是個獨立的java

application,并不是普通的WEB/J2EE應用,而且是單獨運行的,不要什么application

server的配合,這種情況下,我們就需要建立自己的數(shù)據(jù)庫連接池方案了。

1、 DBCP

DBCP是Apache的一個開源項目:

commons.dbcp

DBCP依賴Apache的另外2個開源項目

commons.collections和commons.pool

dbcp包,目前版本是1.2.1:

pool包,目前版本是1.3:,

common-collections包:

下載這些包并將這些包的路徑添加到classpath中就可以使用dbcp做為項目中的數(shù)據(jù)庫連接池使用了。

在建立我們自己的數(shù)據(jù)庫連接池時,可以使用xml文件來傳入需要的參數(shù),這里只使用hard

code的方式來簡單介紹,所有需要我們自己寫的代碼很少,只要建立一個文件如下:

import

org.apache.commons.dbcp.BasicDataSource;

import

org.apache.commons.dbcp.BasicDataSourceFactory;

import

java.sql.SQLException;

import java.sql.Connection;

import

java.util.Properties;

public class ConnectionSource {

private static BasicDataSource dataSource =

null;

public ConnectionSource() {

}

public static void init() {

if (dataSource != null) {

try

{

dataSource.close();

} catch (Exception e)

{

}

dataSource = null;

}

try {

Properties p = new

Properties();

p.setProperty("driverClassName",

"oracle.jdbc.driver.OracleDriver");

p.setProperty("url",

"jdbc:oracle:thin:@192.168.0.1:1521:testDB");

p.setProperty("password", "scott");

p.setProperty("username",

"tiger");

p.setProperty("maxActive", "30");

p.setProperty("maxIdle", "10");

p.setProperty("maxWait",

"1000");

p.setProperty("removeAbandoned",

"false");

p.setProperty("removeAbandonedTimeout",

"120");

p.setProperty("testOnBorrow", "true");

p.setProperty("logAbandoned", "true");

dataSource = (BasicDataSource)

BasicDataSourceFactory.createDataSource(p);

} catch (Exception e) {

}

}

public static synchronized Connection

getConnection() throws SQLException {

if (dataSource == null) {

init();

}

Connection conn = null;

if (dataSource != null) {

conn = dataSource.getConnection();

}

return conn;

}

}

接下來,在我們的應用中,只要簡單地使用ConnectionSource.getConnection()就可以取得連接池中的數(shù)據(jù)庫連接,享受數(shù)據(jù)庫連接帶給我們的好處了。當我們使用完取得的數(shù)據(jù)庫連接后,只要簡單地使用connection.close()就可把此連接返回到連接池中,至于為什么不是直接關(guān)閉此連接,而是返回給連接池,這是因為dbcp使用委派模型來實現(xiàn)Connection接口了。

在使用Properties來創(chuàng)建BasicDataSource時,有很多參數(shù)可以設置,比較重要的還有:

testOnBorrow、testOnReturn、testWhileIdle,他們的意思是當是取得連接、返回連接或連接空閑時是否進行有效性驗證(即是否還和數(shù)據(jù)庫連通的),默認都為false。所以當數(shù)據(jù)庫連接因為某種原因斷掉后,再從連接池中取得的連接,實際上可能是無效的連接了,所以,為了確保取得的連接是有效的,

可以把把這些屬性設為true。當進行校驗時,需要另一個參數(shù):validationQuery,對oracle來說,可以是:SELECT COUNT(*) FROM

DUAL,實際上就是個簡單的SQL語句,驗證時,就是把這個SQL語句在數(shù)據(jù)庫上跑一下而已,如果連接正常的,當然就有結(jié)果返回了。

還有2個參數(shù):timeBetweenEvictionRunsMillis 和

minEvictableIdleTimeMillis,

他們兩個配合,可以持續(xù)更新連接池中的連接對象,當timeBetweenEvictionRunsMillis

大于0時,每過timeBetweenEvictionRunsMillis

時間,就會啟動一個線程,校驗連接池中閑置時間超過minEvictableIdleTimeMillis的連接對象。

還有其他的一些參數(shù),可以參考源代碼。

2、

C3P0:

C3P0是一個開放源代碼的JDBC連接池,C3PO

連接池是一個優(yōu)秀的連接池,推薦使用。C3PO實現(xiàn)了JDBC3.0規(guī)范的部分功能,因而性能更加突出,包括了實現(xiàn)jdbc3和jdbc2擴展規(guī)范說明的Connection 和Statement 池的DataSources 對象。

下載地址:

package

com.systex.utils.web;

import java.beans.PropertyVetoException;

import

java.sql.Connection;

import java.sql.SQLException;

import

javax.sql.DataSource;

import

com.mchange.v2.c3p0.ComboPooledDataSource;

public class C3PODataSource {

private static

ComboPooledDataSource dataSource = null;

private static final String driver

= "com.mysql.jdbc.Driver";

private static final String url =

"jdbc:mysql://localhost:3306/wyd";

private static final String userName =

"root";

private static final String password = "root";

public static DataSource getDataSource() {

if

(dataSource == null) {

dataSource = new ComboPooledDataSource();

try

{

dataSource.setDriverClass(driver);

} catch (PropertyVetoException

e) {

System.out.println("DataSource Load Driver

Exception!!");

e.printStackTrace();

}

dataSource.setJdbcUrl(url);

dataSource.setUser(userName);

dataSource.setPassword(password);

//

設置連接池最大連接容量

dataSource.setMaxPoolSize(20);

//

設置連接池最小連接容量

dataSource.setMinPoolSize(2);

//

設置連接池最大statements對象容量

dataSource.setMaxStatements(100);

}

return

dataSource;

}

public static Connection getConnection() throws

SQLException {

return

C3PODataSource.getDataSource().getConnection();

}

}

3、 Proxool

這是一個Java SQL

Driver驅(qū)動程序,提供了對你選擇的其它類型的驅(qū)動程序的連接池封裝。可以非常簡單的移植到現(xiàn)存的代碼中。完全可配置??焖伲墒?,健壯??梢酝该鞯貫槟悻F(xiàn)存的JDBC驅(qū)動程序增加連接池功能。

官方網(wǎng)站:

下載地址:

網(wǎng)站欄目:java數(shù)據(jù)庫連接池代碼 java druid數(shù)據(jù)庫連接池
網(wǎng)頁路徑:http://m.rwnh.cn/article36/dosgosg.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián),為您提供外貿(mào)網(wǎng)站建設、手機網(wǎng)站建設、企業(yè)網(wǎng)站制作、品牌網(wǎng)站建設、軟件開發(fā)、微信公眾號

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)

成都app開發(fā)公司
太湖县| 勃利县| 慈利县| 根河市| 德兴市| 商城县| 汶川县| 武义县| 金山区| 西安市| 攀枝花市| 洱源县| 阜南县| 济源市| 彝良县| 芦溪县| 深水埗区| 大余县| 阳朔县| 永丰县| 合江县| 封开县| 汤原县| 江源县| 高青县| 中西区| 崇信县| 永丰县| 长葛市| 武穴市| 渝中区| 贞丰县| 凯里市| 舞钢市| 湘阴县| 吉首市| 丰台区| 达孜县| 拉萨市| 上思县| 瓦房店市|