【永恒的瞬间】
☜Give me hapy ☞

在TOMCAT下的conf文件夹中server.xml进行配置,下列代码写在</host>标签之前

<Context path="/mystruts" reloadable="true" docBase="C:MyEclipse Enterprise Workbench 5.1.0 GAworkspacemybbs" workDir="C:MyEclipse Enterprise Workbench 5.1.0 GAworkspacemybbsWEB-INFclasses" debug="5" crossContext="true">

            
<Resource name="jdbc/mysql" auth="Container" type="javax.sql.DataSource"
               maxActive
="100" maxIdle="30" maxWait="10000"
               username
="root" password="root" driverClassName="com.mysql.jdbc.Driver"
               url
="jdbc:mysql://localhost:3306/bbsdb?autoReconnect=true"/>
</Context>
<!--
    配置虚拟目录

-->

然后在配置工程中的WEB.XML文件中加上

 

  <resource-ref>
  
<res-ref-name>jdbc/mysql</res-ref-name>
  
<res-type>javax.sql.DataSource</res-type>
  
<res-auth>Container</res-auth>
  
<res-sharing-scope>Shareable</res-sharing-scope>
  
</resource-ref>

 

建一个数据访问层类,下面是个简单的一个类

 

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;

/**
 * 
@author xu
 *
 
*/

public class DataBase {
    
    Context ctx
=null;
    
private Connection con = null;
    
private DataSource ds = null;
    
private Statement st = null;
    
private ResultSet rs = null;
    
//从连接池获得数据源
    public  DataBase() throws NamingException, SQLException
    
{
        ctx 
= new InitialContext();
        
this.ds = (DataSource)ctx.lookup("java:comp/env/jdbc/mysql");
        
this.con = this.ds.getConnection();
    }

    
    
//从逻辑BEAN获取SQL,返回ReultSet
    public ResultSet getStatement(String sql) throws SQLException
    
{
        st 
= con.createStatement();
        rs 
= st.executeQuery(sql);
        System.out.println(sql);
        
return rs;
    }

    
    
//实现对表的增,删,改
    public int upTable(String sql) throws SQLException
    
{
        st 
= con.createStatement();
        
int i = st.executeUpdate(sql);
        
return i;
    }

    
    
//创建事务和还原事务
    public void createCommit(boolean autoCommit) throws SQLException
    
{
        con.setAutoCommit(autoCommit);
    }

    
    
//提交事务
    public void toCommit() throws SQLException
    
{
        con.commit();
    }

    
    
//回滚事物
    public void backCommit() throws SQLException
    
{
        con.rollback();
    }

    
    
//关闭Connection
    public void closeConnection() throws SQLException
    
{
        
if(con == null)
        
{
            con.close();
        }

    }

    
    
//关闭Statement
    public void closeStatement() throws SQLException
    
{
        
if(st == null)
        
{
            st.close();
        }

    }

    
    
//关闭ResultSet
    public void closeResultSet() throws SQLException
    
{
        
if(rs == null)
        
{
            rs.close();
        }

    }



}
posted on 2008-05-29 11:46 ☜♥☞MengChuChen 阅读(427) 评论(0)  编辑  收藏 所属分类: Tomcat

只有注册用户登录后才能发表评论。


网站导航: