一.配置tomcat连接池
1. 修改server.xml或者在conf/Catalina/localhost下添加对应的xml片段。此处使用的是第二种方法。
在conf/Catalina/localhost文件夹下新建ROOT.xml片段,添加以下内容:
<?xmlversion="1.0"encoding="UTF-8"?>
<Context crossContext="true" useHttpOnly="true">
<Resourcename="jdbc/infogrid" type="javax.sql.DataSource" password="123456" driverClassName="com.mysql.jdbc.Driver" maxIdle="10" maxWait="50" username="root" url="jdbc:mysql://localhost:3306/infogrid?autoReconnect=true" maxActive="20"/>
</Context>
2. 为tomcat添加数据库连接驱动包,本用例使用mysql,将mysql的驱动包添加到common/lib下
二.编写java测试类(该类必须部署在tomcat容器中,否则无法获得JNDI资源)
PreparedStatement ps=null
ResultSet rs=null
try{
InitialContext ctx=new InitialContext()
DataSource dataSource=(DataSource)ctx.lookup("java:comp/env/jdbc/infogrid")
Connection connection=dataSource.getConnection()
ps=connection.prepareStatement("select count(*) from test")
rs=ps.executeQuery()
rs.next()
System.out.println("表中行数为:"+rs.getInt(1))
rs.close()
ps.close()
System.out.println(connection.getClass())
//class org.apache.tomcat.dbcp.dbcp.PoolingDataSource$PoolGuardConnectionWrapper
Field field=connection.getClass().getDeclaredField("delegate")
field.setAccessible(true)
System.out.println(field.get(connection).getClass())
//class org.apache.tomcat.dbcp.dbcp.PoolableConnection
connection.close()
//此关闭并非为真得关闭数据库连接,具体该close实现可见上面的两个Connection代理类,其实只是告诉连接池,该Connection已经用完了,可以被再次利用了
}catch(Exception ex){
ex.printStackTrace()
}
原因:你在context.xml配置文件中写错了;你写的sqlserver 2000 .将下面的替换你原来的。driverClassName="com.microsoft.sqlserver.jdbc.SQLServerDriver"
url="jdbc:sqlserver://localhost:1433DatabaseName=pubs" /> 祝好运~
ps:经过楼上提醒,我说的是sqljdbc和sql2005jdbc的配置。 正如楼上所说也许是你没有将数据库驱动包放入tomcat 的lib包中。
这是我自己写的,肯定好用,参考一下吧。数据库连接的建立和关闭是非常耗费系统资源的 *** 作。数据库连接池的解决方案是在应用程序启动时建立足够的数据库连接,并将这些连接组成一个连接池,由应用程序动态的对池中的连接进行申请、使用和释放。对于多余连接池中的连接数的请求,应在请求队列中排队等待。并且应用程序会根据连接的使用率动态的增加和减少池中的连接数。
连接池技术尽可能多的重用了消耗内存的资源,大大节省了内存,提高了服务器的效率。
不同的版本的tomcat创建连接池的方法是不同的。下面基于tomcat5.5 + MS sql server 2k来说明。
step1:数据库驱动(三个jar)放到$tomcat$/common/lib中。
step2:打开$tomcat$/conf/server.xml,在host下加入如下代码
以下是引用片段:
<Context path="" docBase="D:\myelipseJsp\dsideal\WebRoot" reloadable="true">
<Resource
name="jdbc/xxx"
type="javax.sql.DataSource"
username="sa"
password=""
driverClassName="com.microsoft.jdbc.sqlserver.SQLServerDriver"
url="jdbc:microsoft:sqlserver://localhost:1433DatabaseName=database"
maxActive="300"
maxIdle="100"
maxWait="5000"
removeAbandoned="true"
removeAbandonedTimeout="100"
logAbandoned="true"
/>
</Context>
注:在tomcat6.0下,需要在Resource中加入一句auth="Container"即可。
maxActive是最大激活连接数,这里取值为300,表示同时最多有300个数据库连接。
maxIdle是最大的空闲连接数,这里取值为100,表示即使没有数据库连接时依然可以保持100空闲的连接,而不被清除,随时处于待命状态。
MaxWait是最大等待秒钟数,这里取值5000,表示5秒后超时,也可取值-1,表示无限等待,直到超时为止。
removeAbandoned="true"
removeAbandonedTimeout="100"
logAbandoned="true"
以上三句话也需要加入,其主要作用在于当并发用户超过预定的连接后会有一些连接因为等待而失效,要及时回收这些无效链接。100表示100秒。
在connpool.jsp中使用。
以下是引用片段:
<%@ page contentType="text/htmlcharset=utf-8" language="java" errorPage="" %>
<%@ page import="javax.naming.Context"%>
<%@ page import="javax.sql.DataSource"%>
<%@ page import="javax.naming.InitialContext"%>
<%@ page import="java.sql.*"%>
<html>
<body>
<%
Context ctx = new InitialContext()
DataSource ds = (DataSource)ctx.lookup("java:comp/env/jdbc/xxx")
Connection conn = ds.getConnection()
Statement stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE)
String sql="select * from news"
ResultSet rs=stmt.executeQuery(sql)
while(rs.next()) {%>
您的第一个字段内容为:<%=rs.getString(1)%><br>
<%}%>
<%out.print("数据库 *** 作成功,恭喜你")%>
<%rs.close()
stmt.close()
conn.close()
%>
注意两段代码中的jdbc/xxx为连接池的名字,要保持一致。
当然我们也可以将连接封装起来,作为一个类使用。结合我们以前所讲的dataconn.java,这里我将它们合并为一个类。代码如下:
以下是引用片段:
package dataconn
import java.sql.*
import javax.naming.*
import javax.sql.DataSource
public class dataconn{
ResultSet rs = null
Connection conn=null
Statement stmt=null
//连接池
public static synchronized Connection getConnection() throws Exception
{
try
{
Context initCtx = new javax.naming.InitialContext()
Context envCtx = (Context) initCtx.lookup("java:comp/env")
DataSource ds = (DataSource)envCtx.lookup("jdbc/xxx")
return ds.getConnection()
}
catch(SQLException e)
{
throw e
}
catch(NamingException e)
{
throw e
}
}
//更新数据
public void executeUpdate(String sql) {
try {
conn = getConnection()
}
catch (Exception ex) {
ex.printStackTrace()
}
try {
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE)
stmt.executeUpdate(sql)
}
catch(SQLException ex) {
System.err.println("aq.executeUpdate: " + ex.getMessage())
System.err.println("aq.executeUpadatestrSQL: " + sql)
}
}
//查询数据
public ResultSet executeQuery(String sql) {
rs = null
try {
conn = getConnection()
}
catch (Exception ex) {
ex.printStackTrace()
}
try {
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE)
rs = stmt.executeQuery(sql)
}
catch(SQLException ex) {
System.err.println("aq.executeQuery: " + ex.getMessage())
System.err.println("aq.executeQuerystrSQL: " + sql)
}
return rs
}
public void closeStmt()
{
try{
if(stmt!=null){
stmt.close()
}
}
catch(SQLException e){
e.printStackTrace()
}
}
public void closeConn()
{
try{
if (conn!=null){
conn.close()
}
}
catch(SQLException e){
e.printStackTrace()
}
}
}
此外你要保证你的sqlserver数据库是好用的才行,用这个测试一下
<%@ page contentType="text/htmlcharset=gb2312"%>
<%@ page import="java.sql.*"%>
<html>
<body>
<%
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance()
String url="jdbc:microsoft:sqlserver://localhost:1433DatabaseName=data_2007"
String user="sa"
String password="sa"
Connection conn= DriverManager.getConnection(url,user,password)
Statement stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE)
String sql="select * from userlist"
ResultSet rs=stmt.executeQuery(sql)
while(rs.next()) {%>
您的第一个字段内容为:<%=rs.getString(1)%><br>
您的第二个字段内容为:<%=rs.getString(2)%><br>
您的第三个字段内容为:<%=rs.getString(3)%><br>
<%}%>
<%out.print("数据库 *** 作成功,恭喜你")%>
<%rs.close()
stmt.close()
conn.close()
%>
将上面代码另存为.jsp,注意修改数据库名,用户名和密码,即可测试sql server是否安装成功。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)