JNDI和在tomcat中配置DBCP连接池 元数据的使用 DBUtils框架的使用 多表操作

1 JNDI和在tomcat中配置DBCP连接池

   JNDI(Java Naming and Directory Interface),Java命名和目录接口,它对应于J2SE中的javax.naming包,这套API的主要作用在于:它可以把DataSource对象放在一个Tomcat容器中(JNDI容器),并为容器中的DataSource对象取一个名称,以后程序想获得DataSource对象,只需通过名称检索即可.其核心API为Context,它代表JNDI容器,其lookup方法为检索容器中对应名称的对象。

  a)JNDI是Java命名和目录接口,不同的Web服务器有着不同的实现
  b)不同进程之间,可不同机器之间访问,叫远程访问
  c)JNDI和JDBC一样,都属于JavaEE规则之一
  d)基于tomcat如何配置DBCP连接池
    >>修改tomcat/conf/context.xml文件
    >>加入DB相关的jar包到tomcat/lib目录下   
    >>重新启动tomcat服务器
  e)访问tomcat服务器的JNDI代码如下,是固定的:
    Context tomcatContext = (Context) context.lookup("java:comp/env"); 

package cn.itcast.web.jdbc.web;

import java.io.IOException;
import java.sql.Connection;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;

//通过JNDI远程访问Tomcat服务器中的DBCP连接池
public class JndiServlet extends HttpServlet {
    public void doGet(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {
        try {
            //创建具体Web服务器的JNDI对象
            Context context = new InitialContext();
            //远程查找Web服务器
            Context tomcatContext = (Context) context.lookup("java:comp/env");
            //在Web服务器内远程查找DBCP连接池服务
            DataSource ds = (DataSource) tomcatContext.lookup("tomcatDS");
            //从DBCP连接池中取得一个空闲的连接
            Connection conn = ds.getConnection();
            //显示结果
            if(conn!=null){
                response.setContentType("text/html;charset=UTF-8");
                response.getWriter().write("取得连接");
                conn.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        } 
    }
}

2 元数据的使用

    元数据:数据库、表、列的定义信息。

    Connection.getDatabaseMetaData()

    DataBaseMetaData对象

        ?getURL():返回一个String类对象,代表数据库的URL。

        ?getUserName():返回连接当前数据库管理系统的用户名。

        ?getDatabaseProductName():返回数据库的产品名称。

        ?getDatabaseProductVersion():返回数据库的版本号。

        ?getDriverName():返回驱动驱动程序的名称。

        ?getDriverVersion():返回驱动程序的版本号。

        ?isReadOnly():返回一个boolean值,指示数据库是否只允许读操作。

    元数据- ParameterMetaData

        PreparedStatement.getParameterMetaData()

        ?获得代表PreparedStatement 元数据的ParameterMetaData对象。

        ParameterMetaData对象,getParameterCount() 获得指定参数的个数.

    元数据- ResultSetMetaData

        ResultSet.getMetaData()

        ?获得代表ResultSet对象元数据的ResultSetMetaData对象。

        ResultSetMetaData对象

        ?getColumnCount()返回resultset对象的列数

        ?getColumnName(int column) 获得指定列的名称

        ? getColumnTypeName(int column)获得指定列的类型(Types类)

  1)想取得对数据库相关信息的描述,可以元数据
  2)DatabaseMetaData/DatabaseMetaData dbmd = conn.getMetaData()
  3)ParameterMetaData/ParameterMetaData psmd = pstmt.getParameterMetaData();
  4)ResultSetMetaData/ResultSetMetaData rsmd = rs.getMetaData();

package cn.itcast.web.jdbc.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;

import cn.itcast.web.jdbc.util.JdbcUtil;

//演示三种元数据库的用法
public class Demo1 {
    public static void main(String[] args) throws Exception {
        Connection conn = JdbcUtil.getMySqlConnection();
        String sql = "select * from user";
        PreparedStatement pstmt = conn.prepareStatement(sql);
        ResultSet rs = pstmt.executeQuery();
        //取得结果集的相关元数据
        ResultSetMetaData rsmd = rs.getMetaData();
        int size = rsmd.getColumnCount();
        for(int i=0;i<size;i++){
            //取得每列的列名
            String columnName = rsmd.getColumnName(i+1);
            //取得每列的类型
            int typeCode = rsmd.getColumnType(i+1);
            System.out.println(columnName+":"+typeCode);
        }
        /*取是有关SQL的相关元数据
        String sql = "insert into user(username,password,birthday,salary) values(?,?,?,?)";
        ParameterMetaData psmd = pstmt.getParameterMetaData();
        int size = psmd.getParameterCount();
        System.out.println("共有" + size+"个参数");
        */
        /*取得DataBaseMetaData
        DatabaseMetaData dbmd = conn.getMetaData();
        String driver = dbmd.getDriverName();
        String url = dbmd.getURL();
        int level = dbmd.getDefaultTransactionIsolation();
        String productName = dbmd.getDatabaseProductName();
        boolean flag = dbmd.isReadOnly();
        System.out.println("flag="+flag);
        System.out.println("driver="+driver);
        System.out.println("url="+url);
        System.out.println("level="+level);
        System.out.println("productName="+productName);
        */
    }
}
package cn.itcast.web.jdbc.dao;

import java.sql.Connection;
import java.sql.ParameterMetaData;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;

import org.apache.commons.beanutils.BeanUtils;

import cn.itcast.web.jdbc.domain.User;
import cn.itcast.web.jdbc.util.JdbcUtil;

//使用元数据+反射优化CURD操作
public class Demo2 {
    public static void main(String[] args) throws Exception {
        //String sql = "insert into user(username,password,birthday,salary) values(?,?,?,?)";
        //Object[] params = {"sisi","000000","2011-10-28",5000};
        //String sql = "update user set username=? where username=?";
        //String sql = "delete from user where id = ?";
        //update(sql,new Object[]{2});
        String sql = "select * from user where id = ?";
        User user = (User) query(sql,new Object[]{1},User.class);
        System.out.println("用户名:" + user.getUsername());
        System.out.println("密码:" + user.getPassword());
        System.out.println("生日:" + user.getBirthday().toLocaleString());
        System.out.println("薪水:" + user.getSalary());
    }  
    //R操作(通用的方法)
    public static Object query(String sql,Object[] params,Class clazz) throws Exception {
        Object obj = clazz.newInstance();
        Connection conn = JdbcUtil.getMySqlConnection();
        PreparedStatement pstmt = conn.prepareStatement(sql);
        ParameterMetaData psmd = pstmt.getParameterMetaData();
        int size = psmd.getParameterCount();
        for(int i=0;i<size;i++){
            pstmt.setObject(i+1,params[i]);
        }
        ResultSet rs = pstmt.executeQuery();
        if(rs.next()){
            //取得结果集元数据
            ResultSetMetaData rsmd = rs.getMetaData();
            //取得结果集列数目
            size = rsmd.getColumnCount();
            //以列值为单位,设置到JavaBean中去
            for(int i=0;i<size;i++){
                //取得列名
                String columnName = rsmd.getColumnName(i+1);
                //通过BeanUtils框架为JavaBean设置值
                BeanUtils.setProperty(obj,columnName,rs.getObject(i+1));
            }
        }
        JdbcUtil.close(rs);
        JdbcUtil.close(pstmt);
        JdbcUtil.close(conn);
        return obj;
    }    
    //CUD操作(通用的方法)
    public static void update(String sql,Object[] params) throws SQLException {
        Connection conn = JdbcUtil.getMySqlConnection();
        PreparedStatement pstmt = conn.prepareStatement(sql);
        //取得参数元数据
        ParameterMetaData psmd = pstmt.getParameterMetaData();
        //取得参数的个数
        int size = psmd.getParameterCount();
        //循环绑定对象的值
        for(int i=0;i<size;i++){
            pstmt.setObject(i+1,params[i]);
        }
        //执行
        pstmt.executeUpdate();
        //关闭对应的连接对象
        JdbcUtil.close(conn);    
        JdbcUtil.close(pstmt);
    }
}

*3 DBUtils框架的使用

    commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库,它是对JDBC的简单封装,学习成本极低,并且使用dbutils能极大简化jdbc编码的工作量,同时也不会影响程序的性能。因此dbutils成为很多不喜欢hibernate的公司的首选。

    API介绍:

        ?org.apache.commons.dbutils.QueryRunner(类)

        ?org.apache.commons.dbutils.ResultSetHandler(接口)

        工具类

            ?org.apache.commons.dbutils.DbUtils。

    QueryRunner类

    该类简单化了SQL查询,它与ResultSetHandler组合在一起使用可以完成大部分的数据库操作,能够大大减少编码量。

    QueryRunner类提供了两个构造方法:

        ?默认的构造方法

        ?需要一个 javax.sql.DataSource 来作参数的构造方法。

    QueryRunner类的主要方法

        ?public Object query(Connection conn, String sql, Object[] params, ResultSetHandler rsh) throws SQLException:执行一个查询操作,在这个查询中,对象数组中的每个元素值被用来作为查询语句的置换参数。该方法会自行处理 PreparedStatement 和 ResultSet 的创建和关闭。

        ?public Object query(String sql, Object[] params, ResultSetHandler rsh) throws SQLException: 几乎与第一种方法一样;唯一的不同在于它不将数据库连接提供给方法,并且它是从提供给构造方法的数据源(DataSource) 或使用的setDataSource 方法中重新获得 Connection。

        ?public Object query(Connection conn, String sql, ResultSetHandler rsh) throws SQLException : 执行一个不需要置换参数的查询操作。

        ?public int update(Connection conn, String sql, Object[] params) throws SQLException:用来执行一个更新(插入、更新或删除)操作。

        ?public int update(Connection conn, String sql) throws SQLException:用来执行一个不需要置换参数的更新操作。

    ResultSetHandler接口

        ?该接口用于处理 java.sql.ResultSet,将数据按要求转换为另一种形式。

        ?ResultSetHandler 接口提供了一个单独的方法:Object handle (java.sql.ResultSet .rs)。

    ResultSetHandler 接口的实现类

        ?BeanHandler:将结果集中的第一行数据封装到一个对应的JavaBean实例中。

        ?BeanListHandler:将结果集中的每一行数据都封装到一个对应的JavaBean实例中,存放到List里。

        ?ArrayHandler:把结果集中的第一行数据转成对象数组。

        ?ArrayListHandler:把结果集中的每一行数据都转成一个对象数组,再存放到List中。

    ResultSetHandler 接口的实现类

        ?MapHandler:将结果集中的第一行数据封装到一个Map里,key是列名,value就是对应的值。

        ?MapListHandler:将结果集中的每一行数据都封装到一个Map里,然后再存放到List。

        ?ScalarHandler:结果集中只有一行一列数据。

    DbUtils类

        ?DbUtils :提供如关闭连接、装载JDBC驱动程序等常规工作的工具类,里面的所有方法都是静态的。主要方法如下:

        ?public static void close(…) throws java.sql.SQLException: DbUtils类提供了三个重载的关闭方法。这些方法检查所提供的参数是不是NULL,如果不是的话,它们就关闭Connection、Statement和ResultSet。

        ?public static void closeQuietly(…): 这一类方法不仅能在Connection、Statement和ResultSet为NULL情况下避免关闭,还能隐藏一些在程序中抛出的SQLException。

        ?public static void commitAndCloseQuietly(Connection conn):用来提交连接,然后关闭连接,并且在关闭连接时不抛出SQL异常。

        ?public static boolean loadDriver(java.lang.String driverClassName):这一方装载并注册JDBC驱动程序,如果成功就返回true。使用该方法,你不需要捕捉这个异常ClassNotFoundException。
  1)目的:减化CURD操作
  2)DBUtils框架最核心的类,就是QueryRunner类,构造其有二种方式
    a)空参构造
    b)通过DataSource构造
  3)DBUtils对象的update()方法,内部已经关闭相关的连接对象
  4)update(Connection)方法带有Connection对象的,需要手工关闭,其它对象自动关闭,update()方法无Connection对象的,DBUtils框架自动关闭
  5)为什么作者要这样设计:主要考虑了在分层结构中,需要用到同一个Connection的问题
  6)对于query()操作与update()操作有着一致的含义
  7)对于query()操作的实现类含义如下;
    BeanHandler/BeanListHandler:针对JavaBean
    ArrayHandler/ArrayListHandler:针对数组
    MapHandler/MapListHandler:针对Map
    ScalarHandler:针对Long

package cn.itcast.web.jdbc.dao;

import java.sql.Connection;
import java.sql.SQLException;

import org.apache.commons.dbutils.QueryRunner;

import cn.itcast.web.jdbc.util.JdbcUtil;

//演示DBUtils框架的使用
public class Demo3 {
    public static void main(String[] args) throws SQLException {
        //QueryRunner runner = new QueryRunner(JdbcUtil.getDataSource());
        //String sql = "insert into user(username,password,birthday,salary) values(?,?,?,?)";
        //String sql = "update user set username=? where username=?";
        //String sql = "delete from user where id = ?";
        //runner.update(sql,new Object[]{4});
        
        Connection conn = JdbcUtil.getMySqlConnection();
        QueryRunner runner = new QueryRunner();
        String sql = "insert into user(username,password,birthday,salary) values(?,?,?,?)";
        runner.update(conn,sql,new Object[]{"tim","111222","2011-10-10",5000});        
        JdbcUtil.close(conn);
    }
}
package cn.itcast.web.jdbc.dao;

import java.sql.SQLException;
import java.util.List;
import java.util.Map;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ArrayHandler;
import org.apache.commons.dbutils.handlers.ArrayListHandler;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.MapHandler;
import org.apache.commons.dbutils.handlers.MapListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;
import org.junit.Test;

import cn.itcast.web.jdbc.domain.User;
import cn.itcast.web.jdbc.util.JdbcUtil;

//演示ResultSetHandler接口的各种实现类的用法
public class Demo4 {
    @Test
    public void testBeanHandler() throws SQLException{
        QueryRunner runner = new QueryRunner(JdbcUtil.getDataSource());
        String sql = "select * from user";
        User user = (User) runner.query(sql,new BeanHandler(User.class));
        System.out.println("用户名:" + user.getUsername());
    }
    @Test
    public void testBeanListHandler() throws SQLException{
        QueryRunner runner = new QueryRunner(JdbcUtil.getDataSource());
        String sql = "select * from user";
        List<User> userList = (List<User>) runner.query(sql,new BeanListHandler(User.class));
        for(User user : userList){
            System.out.println("用户名:" + user.getUsername());
            System.out.println("密码:" + user.getPassword());
        }
    }
    @Test
    public void testArrayHandler() throws SQLException{
        QueryRunner runner = new QueryRunner(JdbcUtil.getDataSource());
        String sql = "select * from user";
        Object[] array = (Object[]) runner.query(sql,new ArrayHandler());
        System.out.println("编号 : " + array[0]);
        System.out.println("用户名 : " + array[1]);
    }
    @Test
    public void testArrayListHandler() throws SQLException{
        QueryRunner runner = new QueryRunner(JdbcUtil.getDataSource());
        String sql = "select * from user";
        List<Object[]> list = (List<Object[]>) runner.query(sql,new ArrayListHandler());
        for(Object[] array : list){
            System.out.print("编号 : " + array[0] + "\t");
            System.out.println("用户名 : " + array[1]);
        }
    }
    @Test
    public void testMapHandler() throws SQLException{
        QueryRunner runner = new QueryRunner(JdbcUtil.getDataSource());
        String sql = "select * from user";
        Map<Object,Object> map = (Map<Object, Object>) runner.query(sql,new MapHandler());
        System.out.println("用户名:" + map.get("username"));
    }
    @Test
    public void testMapListHandler() throws SQLException{
        QueryRunner runner = new QueryRunner(JdbcUtil.getDataSource());
        String sql = "select * from user";
        List<Map<Object,Object>> list = (List<Map<Object, Object>>) runner.query(sql,new MapListHandler());
        for(Map<Object,Object> map : list){
            System.out.println("用户名:" + map.get("username"));
            System.out.println("薪水:" + map.get("salary"));
        }
    }
    @Test
    public void testScalarHandler() throws SQLException{
        QueryRunner runner = new QueryRunner(JdbcUtil.getDataSource());
        String sql = "select count(*) from user";
        Long sum = (Long) runner.query(sql,new ScalarHandler());
        System.out.println("共有" + sum + "人");
    }
}

4  多表操作
  a)一对多或多对一
    表结构只有单向关联,类具有双向关联
    项目中,将所有的内容全部取出来,根据用户需求来有条件加载对应的值,加延迟加载 

  b)多对多
    以空间换时间,允许创建非标准的表

不管java的对象存在何种关系,反映到关系型数据库中,都是使用单向外键表示记录(即对象)的关联关系。

设计java对象如涉及到多个对象相互引用,要尽量避免使用一对多,或多对多关系,而应使用多对一描述对象之间的关系(或使用延迟加载的方式)。

select查询多表会影响性能,所以有时允许适当的数据冗余。)以空间换时间。

 

package cn.itcast.web.jdbc.dao;

import java.util.ArrayList;
import java.util.List;
import cn.itcast.web.jdbc.domain.Department;
import cn.itcast.web.jdbc.domain.Employee;
public class One2ManyTest {
    public static void main(String[] args) throws Exception {
        Department d = new Department();
        d.setName("软件部");
        
        Employee e1 = new Employee();
        e1.setName("小王");

        Employee e2 = new Employee();
        e2.setName("小何");
        
        List<Employee> employeeList = new ArrayList<Employee>();
        employeeList.add(e1);
        employeeList.add(e2);
        
        d.setEmployeeList(employeeList);
        e1.setDepartment(d);
        e2.setDepartment(d);
        
        //保存部门记录时,同时保存对应的员工记录
        Dao dao = new Dao();
        dao.save(d);
    }
}
package cn.itcast.web.jdbc.dao;

import java.util.ArrayList;
import java.util.List;

import cn.itcast.web.jdbc.domain.Student;
import cn.itcast.web.jdbc.domain.Teacher;

public class Many2ManyTest {
    public static void main(String[] args) throws Exception {
        Teacher t1 = new Teacher();
        t1.setName("赵");

        Teacher t2 = new Teacher();
        t2.setName("蔡");
        
        Student s1 = new Student();
        s1.setName("小王");
        
        Student s2 = new Student();
        s2.setName("小何");
        
        List<Teacher> teacherList = new ArrayList<Teacher>();
        teacherList.add(t1);
        teacherList.add(t2);
        
        List<Student> studentList = new ArrayList<Student>();
        studentList.add(s1);
        studentList.add(s2);
        
        t1.setStudentList(studentList);
        t2.setStudentList(studentList);
        s1.setTeacherList(teacherList);
        s2.setTeacherList(teacherList);
        
        Dao dao = new Dao();
        dao.save(t1);
    }
}
package cn.itcast.web.jdbc.dao;

import java.sql.SQLException;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ArrayHandler;
import cn.itcast.web.jdbc.domain.Department;
import cn.itcast.web.jdbc.domain.Employee;
import cn.itcast.web.jdbc.domain.Student;
import cn.itcast.web.jdbc.domain.Teacher;
import cn.itcast.web.jdbc.util.JdbcUtil;

public class Dao {
    public void save(Department d) throws SQLException {
        if(d==null){
            throw new SQLException();
        }
        QueryRunner runner = new QueryRunner(JdbcUtil.getDataSource());
        
        //NO1:向department表中插入一条记录
        String sql = "insert into department(name) values(?)";
        runner.update(sql,d.getName());
        
        //NO2:取得插入department表中的主键
        sql = "select id from department where name = ?";
        Object[] array = (Object[]) runner.query(sql,d.getName(),new ArrayHandler());
        int did = (Integer) array[0];
        
        //NO3:向employee表中插入N条记录
        sql = "insert into employee(name,did) values(?,?)";
        for(Employee e : d.getEmployeeList()){
            runner.update(sql,new Object[]{e.getName(),did});
        }
    }
    public void save(Teacher t) throws SQLException {
        if(t==null){
            throw new SQLException();
        }
        QueryRunner runner = new QueryRunner(JdbcUtil.getDataSource());
        
        //NO1:向teacher表中插入一条记录
        String sql = "insert into teacher(name) values(?)";
        runner.update(sql,t.getName());
        
        //NO2:取得teacher表中插入记录的主键
        sql = "select id from teacher where name = ?";
        Object[] array = (Object[]) runner.query(sql,t.getName(),new ArrayHandler());
        int tid = (Integer) array[0];
        
        //NO3:向student表中插入N条记录
        sql = "insert into student(name) values(?)";
        for(Student s : t.getStudentList()){
            runner.update(sql,s.getName());
            
            //NO4:取得student表中插入记录的主键
            String temp1 = "select id from student where name = ?";
            array = (Object[]) runner.query(temp1,s.getName(),new ArrayHandler());
            int sid = (Integer)array[0];
            
            //NO5:向middle表中插入N条记录
            String temp2 = "insert into middle(tid,sid) values(?,?)";
            runner.update(temp2,new Object[]{tid,sid});
            
        }
        
    }
}
package cn.itcast.web.jdbc.domain;

import java.util.ArrayList;
import java.util.List;

public class Teacher {
    private int id;
    private String name;
    private List<Student> studentList = new ArrayList<Student>();
    public Teacher(){}
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public List<Student> getStudentList() {
        return studentList;
    }
    public void setStudentList(List<Student> studentList) {
        this.studentList = studentList;
    }
}
package cn.itcast.web.jdbc.domain;

import java.util.ArrayList;
import java.util.List;

public class Student {
    private int id;
    private String name;
    private List<Teacher> teacherList = new ArrayList<Teacher>();
    public Student(){}
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public List<Teacher> getTeacherList() {
        return teacherList;
    }
    public void setTeacherList(List<Teacher> teacherList) {
        this.teacherList = teacherList;
    }
}


*5 客户资料系统
  1)${d==date?‘selected‘:‘‘}
    ${}EL中的值,一定要从域中取,不会默认某个域 
  2)通过JS取得需要删除客户的ID:
        //定位到tableID所对应的元素,即<table>标签
            var tableElement = document.getElementById("tableID");
            var size = tableElement.rows.length;//size=5
            //装ID号的数组
            var ids = "";
            for(var i=1;i<=size-2;i++){
                //取得每行的1列中的checkbox元素
                var checkboxElement = tableElement.rows(i).cells(0).firstChild;
                //如果该复选框被选中
                if(checkboxElement.checked){
                    //收集该复选框的ID值
                    ids += checkboxElement.value + "_";
                }
            }
            //ids="1_2_3_"
            var url = "/day15/CrmServlet?method=deleteCustomerById&ids="+ids;
            window.location.href = url;

思考:
1)当批量删除客户信息时,如果确保事务的操作呢?

郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。