怎么在JAVA中创建一个数据库连接池求实例代码

怎么在JAVA中创建一个数据库连接池求实例代码,第1张

用c3po来创建数据库连接池

1到网络上下载c3p0-0904jar包,导入工程;(注意以下方法只能用于web服务).

2找出web服务器中conf目录下的cententxml,在里面加上以下配置

<Resource auth="Container"

description="DB Connection"

driverClass="commysqljdbcDriver"

maxPoolSize="4"

minPoolSize="2"

acquireIncrement="1"

name="jdbc/TestDB"

user="root"

password="root"

factory="orgapachenamingfactoryBeanFactory"

type="commchangev2c3p0ComboPooledDataSource"

jdbcUrl="jdbc:mysql://localhost:3306/自己的数据库名autoReconnect=true" />

3java获取连接池代码

import javasqlConnection;

import javasqlSQLException;

import javaxnamingInitialContext;

import javaxnamingNamingException;

import javaxsqlDataSource;

public class DBUtils {

static InitialContext ic;

static DataSource ds;

static{

try {

ic = new InitialContext();

ds = (DataSource)iclookup("java:comp/env/jdbc/TestDB");

} catch (NamingException e) {

// TODO Auto-generated catch block

eprintStackTrace();

}

}

public static Connection getCon() {

try {

return dsgetConnection();

} catch (SQLException e) {

// TODO Auto-generated catch block

eprintStackTrace();

return null;

}

}

}

通过以上代码,即可获取连接池中的连接.

java中使用jdbc连接sql server数据库步骤:

1JDBC连接SQL Server的驱动安装 ,前两个是属于数据库软件,正常安装即可(注意数据库登陆不要使用windows验证)

<1> 将JDBC解压缩到任意位置,比如解压到C盘program files下面,并在安装目录里找到sqljdbcjar文件,得到其路径开始配置环境变量

在环境变量classpath 后面追加 C:\Program Files\Microsoft SQL Server2005 JDBC Driver\sqljdbc_12\enu\sqljdbcjar

<2> 设置SQLEXPRESS服务器:

a打开SQL Server Configuration Manager -> SQLEXPRESS的协议 -> TCP/IP

b右键单击启动TCP/IP

c双击进入属性,把IP地址中的IP all中的TCP端口设置为1433

d重新启动SQL Server 2005服务中的SQLEXPRESS服务器

e关闭SQL Server Configuration Manager

<3> 打开 SQL Server Management Studio,连接SQLEXPRESS服务器, 新建数据库,起名字为sample

<4> 打开Eclipse

a新建工程-> Java -> Java project,起名为Test

b选择eclipse->窗口->首选项->Java->installed JRE 编辑已经安装好的jdk,查找目录添加sqljdbcjar

c右键单击目录窗口中的Test, 选择Build Path ->Configure Build Path, 添加扩展jar文件,即把sqljdbcjar添加到其中

<5> 编写Java代码来测试JDBC连接SQL Server数据库

import javasql;

public class Test {

public static void main(String[] srg) {

//加载JDBC驱动

String driverName = "commicrosoftsqlserverjdbcSQLServerDriver";

//连接服务器和数据库sample

String dbURL = "jdbc:sqlserver://localhost:1433; DatabaseName=sample";

String userName = "sa"; //默认用户名

String userPwd = "123456"; //密码

Connection dbConn;

try {

ClassforName(driverName);

dbConn = DriverManagergetConnection(dbURL, userName, userPwd);

Systemoutprintln("Connection Successful!"); //如果连接成功 控制台输出

} catch (Exception e) {

eprintStackTrace();

}

}

}

执行以后就可以连接到sample数据库了。

Java程序向数据库中插入数据,代码如下:

//首先创建数据库,(aess,oracle,mysql,sqlsever)其中之一,其中aess,sqlsever需要配置数据源(odbc);

//然后再eclipse中创建类(ConnDb,Test,TestBean)ConnDb功能为连接数据库,查询,插入,删除,修改数据的类,Test为含有main方法的测试类,TestBean为数据表中的字段属性及set,get方法

//以下是ConnDb代码:

packagedb;

importjavasqlConnection;

importjavasql;

import

javasqlResultSet;

importjavasql;

import

javasqlStatement;

importjavautilArrayList;

publicclassConnDb{

publicConnectionstartConn(Connectionconn){

try{

ClassforName("sunjdbcodbc");

conn=("jdbc:odbc:数据库","用户名","密码");

}catch(Exceptione){

Systemoutprintln("连接数据库时出现错误");

}

returnconn;

}

publicArrayList(Stringsql){

Connectionconn=null;

Statementstmt=null;

ResultSetrs=null;

ArrayListlist=newArrayList();

try{

conn=startConn(conn);

stmt=conn();

rs=stmt(sql);//sql为sql语句例如"selectfrom

表名",从main方法中传进来,这里用的是ArrayList类将查询结果存储起来

while(rsnext()){

TestBeantb=newTestBean();

tbsetTid(rsgetString("tid"));

tbsetTname(rsgetString("tname"));

tbsetTinfo(rsgetString("tinfo"));

listadd(tb);

}

}

catch(e){

//TODOAuto-generatedcatchblock

e();

}finally{

closeConn(rs,stmt,conn);

}

returnlist;

}

publicvoid(Stringsql){

Connectionconn=null;

Statementstmt=null;

try{

conn=

startConn(conn);

stmt=conn();

stmt(sql);

}

catch(e){

Systemoutprintln("修改,插入或者删除数据库数据时发生错误!");

}finally{

closeConn(stmt,conn);

}

}

publicvoidcloseConn(ResultSetrs,Statementstmt,Connectionconn){

try{

if(rs!=

null){

rsclose();

}

if(stmt!=null){

stmtclose();

}

if(conn!=null){

connclose();

}

}

catch(e){

//TODOAuto-generatedcatch

block

Systemoutprintln("关闭数据库的时候发生错误!");

}

}

publicvoidcloseConn(Statementstmt,Connectionconn){

try{

if(stmt!=null){

stmtclose();

}

if(conn!=null){

connclose();

}

}

catch(e){

//TODOAuto-generatedcatchblock

Systemoutprintln("关闭数据库的时候发生错误!");

}

}

}

下面是一个简单的连接MySQL数据库,并 *** 作数据库表的例子:

import javasql;

public class TestMysql {

public static void main(String[] args) {

Connection conn = null;

Statement stmt = null;

ResultSet rs = null;

try {

//加载驱动

ClassforName("commysqljdbcDriver");

//创建连接

conn = DriverManager

getConnection("jdbc:mysql://localhost/bbsuser=用户名&password=密码");

stmt = conncreateStatement();

rs = stmtexecuteQuery("select from user");

while (rsnext()) {

String user = rsgetString(1);

String password = rsgetString(2);

Systemoutprintln("用户名:" + user + "," +" 密码:" + password );

}

} catch (ClassNotFoundException ex) {

exprintStackTrace();

} catch (SQLException ex) {

exprintStackTrace();

} finally {

try {

if (rs != null) {

rsclose();

rs = null;

}

if (stmt != null) {

stmtclose();

stmt = null;

}

if (conn != null) {

connclose();

conn = null;

}

} catch (SQLException e) {

eprintStackTrace();

}

}

}

}

当然前提是要把MySQL的连接驱动JAR文件添加到工程里

以上就是关于怎么在JAVA中创建一个数据库连接池求实例代码全部的内容,包括:怎么在JAVA中创建一个数据库连接池求实例代码、请教SQLCipher在Windows下如何通过Java连接创建数据库、java中怎么向数据库插入数据(java怎么导入数据库)等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/sjk/9415599.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-04-28
下一篇 2023-04-28

发表评论

登录后才能评论

评论列表(0条)

保存