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怎么导入数据库)等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)