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）当批量删除客户信息时，如果确保事务的操作呢？