实验6

课程名称	数据库系统概论实验
实验项目名称	JDBC进阶（3）

实验目的：

掌握批量SQL语句执行的方法，理解DAO和ORM的基本概念

实验内容：

利用批量SQL语句执行的方法实现实验5中的最后两个方法：

编写批量借阅读书函数： public void lendbooks(String readerId,Collection barcodes) … 。其中第二个参数为图书条码集合。

public void lendbooks(String readerId,Collection<String> barcodes) throws BaseException {Object[] objects = barcodes.toArray();for (int i = 0; i < objects.length; i++) {lend((String) objects[i],readerId);}
}

编写批量设置罚金函数：public void setPenalSum(String readerId,Map<String,Double> penalSums) … 。其中第二个参数的key为barcode，value为改读者尚未归还图书的罚金（注意，不要设置已经归还图书的罚金）。

public void setPenalSum(String readerId,Map<String,Double> penalSums) throws Exception {Connection conn = null;PreparedStatement ps = null;try {conn = DBUtil.getConnection();String sql = "update beanbooklendrecord set penalSum = ? where readerid = ? and bookBarcode = ? and returnDate is null";ps = conn.prepareStatement(sql);ps.setObject(2,readerId);for (Map.Entry<String,Double> x : penalSums.entrySet()) {String barcode = x.getKey();double penal = x.getValue();ps.setObject(1,penal);ps.setObject(3,barcode);ps.execute();}} catch (SQLException e) {e.printStackTrace();} finally {DBUtil.closeResorce(conn,ps);}
}

模仿SystemUserDAO类，实现BookDAO类，并改造BookManager类，使之通过BookDAO操作数据库。

给出BookDAO类代码。

package cn.edu.zucc.booklib.dao;import cn.edu.zucc.booklib.model.BeanBook;
import cn.edu.zucc.booklib.util.BaseException;
import cn.edu.zucc.booklib.util.BusinessException;
import cn.edu.zucc.booklib.util.DBUtil;
import cn.edu.zucc.booklib.util.DbException;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;public class BookDAO {public List<BeanBook> searchBook(String keyword, String bookState) throws BaseException {List<BeanBook> result = new ArrayList<BeanBook>();Connection conn = null;try {conn = DBUtil.getConnection();String sql = "select * from view_book" + " where state='" + bookState + "' ";if (keyword != null && !"".equals(keyword))sql += " and (bookname like ? or barcode like ?)";sql += " order by barcode";java.sql.PreparedStatement pst = conn.prepareStatement(sql);if (keyword != null && !"".equals(keyword)) {pst.setString(1, "%" + keyword + "%");pst.setString(2, "%" + keyword + "%");}java.sql.ResultSet rs = pst.executeQuery();while (rs.next()) {BeanBook b = new BeanBook();b.setBarcode(rs.getString(1));b.setBookname(rs.getString(2));b.setPubid(rs.getString(3));b.setPrice(rs.getDouble(4));b.setState(rs.getString(5));b.setPubName(rs.getString(6));result.add(b);}} catch (SQLException e) {e.printStackTrace();throw new DbException(e);} finally {if (conn != null)try {conn.close();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}return result;}public void createBook(BeanBook b) throws BaseException {if (b.getBarcode() == null || "".equals(b.getBarcode()) || b.getBarcode().length() > 20) {throw new BusinessException("条码必须是1-20个字");}if (b.getBookname() == null || "".equals(b.getBookname()) || b.getBookname().length() > 50) {throw new BusinessException("图书名称必须是1-50个字");}Connection conn = null;try {conn = DBUtil.getConnection();String sql = "select * from BeanBook where barcode=?";PreparedStatement pst = conn.prepareStatement(sql);pst.setString(1, b.getBarcode());ResultSet rs = pst.executeQuery();if (rs.next()) throw new BusinessException("条码已经被占用");rs.close();pst.close();sql = "insert into BeanBook(barcode,bookname,pubid,price,state) values(?,?,?,?,'在库')";PreparedStatement ps = conn.prepareStatement(sql);ps.setObject(1, b.getBarcode());ps.setObject(2, b.getBookname());ps.setString(3, b.getPubid());ps.setDouble(4, b.getPrice());ps.execute();pst.close();} catch (SQLException e) {e.printStackTrace();throw new DbException(e);} finally {if (conn != null)try {conn.close();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}public void modifyBook(BeanBook b) throws BaseException {if (b.getBookname() == null || "".equals(b.getBookname()) || b.getBookname().length() > 50) {throw new BusinessException("图书名称必须是1-50个字");}Connection conn = null;try {conn = DBUtil.getConnection();String sql = "select * from BeanBook where barcode=?";java.sql.PreparedStatement pst = conn.prepareStatement(sql);pst.setString(1, b.getBarcode());java.sql.ResultSet rs = pst.executeQuery();if (!rs.next()) throw new BusinessException("图书不存在");rs.close();pst.close();sql = "update BeanBook set bookname=?,pubid=?,price=?,state=? where barcode=?";pst = conn.prepareStatement(sql);pst.setString(1, b.getBookname());pst.setString(2, b.getPubid());pst.setDouble(3, b.getPrice());pst.setString(4, b.getState());pst.setString(5, b.getBarcode());pst.execute();pst.close();} catch (SQLException e) {e.printStackTrace();throw new DbException(e);} finally {if (conn != null)try {conn.close();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}public BeanBook loadBook(String barcode) throws DbException {Connection conn = null;try {conn = DBUtil.getConnection();String sql = "select * from view_book " + " where barcode=? ";java.sql.PreparedStatement pst = conn.prepareStatement(sql);pst.setString(1, barcode);java.sql.ResultSet rs = pst.executeQuery();if (rs.next()) {BeanBook b = new BeanBook();b.setBarcode(rs.getString(1));b.setBookname(rs.getString(2));b.setPubid(rs.getString(3));b.setPrice(rs.getDouble(4));b.setState(rs.getString(5));b.setPubName(rs.getString(6));return b;}} catch (SQLException e) {e.printStackTrace();throw new DbException(e);} finally {if (conn != null)try {conn.close();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}return null;}
}

给出改造后BookManager类的各个方法的代码。

public List<BeanBook> searchBook(String keyword, String bookState) throws BaseException, SQLException {Connection conn = null;try {conn = DBUtil.getConnection();return dao.searchBook(keyword, bookState);} catch (SQLException e) {e.printStackTrace();} catch (BaseException e) {e.printStackTrace();} finally {if (conn != null) {try {conn.close();} catch (SQLException e) {e.printStackTrace();}}}return null;
}public void createBook(BeanBook b) throws BaseException, SQLException {Connection conn = null;try {conn = DBUtil.getConnection();dao.createBook(b);} catch (SQLException e) {e.printStackTrace();} catch (BaseException e) {e.printStackTrace();} finally {if (conn != null) {try {conn.close();} catch (SQLException e) {e.printStackTrace();}}}
}public void modifyBook(BeanBook b) throws BaseException, SQLException {Connection conn = null;try {conn = DBUtil.getConnection();dao.modifyBook(b);} catch (SQLException e) {e.printStackTrace();} catch (BaseException e) {e.printStackTrace();} finally {if (conn != null) {try {conn.close();} catch (SQLException e) {e.printStackTrace();}}}
}public BeanBook loadBook(String barcode) throws DbException, SQLException {Connection conn = null;try {conn = DBUtil.getConnection();dao.loadBook(barcode);} catch (SQLException e) {e.printStackTrace();} catch (DbException e) {e.printStackTrace();} finally {if (conn != null) {try {conn.close();} catch (SQLException e) {e.printStackTrace();}}}return null;
}

在BaseDAO中，增加方法，实现根据主码提取对象的方法load。

写出函数代码

ublic T load(Connection conn, Class<T> clazz, Map<String,Object> primaryKey) {PreparedStatement ps = null;ResultSet rs = null;try {//primayKey的key为主码的各个属性名称，value为主码值//假设对象的类名和表名一致，属性名和字段名一致String tableName = clazz.getSimpleName();String sql = "select * from "+tableName+" where"; //动态构建sqlfor (Map.Entry mp : primaryKey.entrySet()) {sql += " " + mp.getKey().toString() + " = ? and";}sql = sql.substring(0,sql.length()-3);Object[] parmas = new Object[primaryKey.size()];//从map中获取参数值，并写入paramsint pos = 0;for (Map.Entry<String, Object> mp : primaryKey.entrySet()) {parmas[pos++] = mp.getValue();}ps = conn.prepareStatement(sql);for (int i = 0; i < parmas.length; i++) {ps.setObject(i+1,parmas[i]);}rs = ps.executeQuery();ResultSetMetaData rsmd = rs.getMetaData();if (rs.next()) {T t = clazz.getDeclaredConstructor().newInstance();for (int i = 0; i < rsmd.getColumnCount(); i++) {//获取当前rs指针的i+1字段的值Object value = rs.getObject(i+1);//获取当前rs指针的i+1字段的列名String columnLable = rsmd.getColumnLabel(i+1);//将value赋值给对应属性，反射Field field = clazz.getDeclaredField(columnLable);field.setAccessible(true);field.set(t, value);}return t;}} catch (Exception e) {e.printStackTrace();} finally {DBUtil.closeResorce(null,ps,rs);}return null;
}

ZUCC_数据库系统概论实验_实验六 JDBC进阶 3相关推荐

（数据库系统概论|王珊）第六章关系数据理论-第一节：为什么要研究关系数据理论
文章目录一:概念回顾:关系模式二:数据依赖三:一个例子:不遵循关系数据理论导致的问题一句话,研究关系数据库理论就是为了设计出合适的关系模式,也即合适.高效的表一:概念回顾:关系模式相关文章 ...
java基本语句回文数实验_实验二 java基本数据类型与把持语句.doc
实验二 java基本数据类型与把持语句.doc 还剩 4页未读, 继续阅读下载文档到电脑,马上远离加班熬夜! 亲,喜欢就下载吧,价低环保! 内容要点: 5System.out.println(num ...
ZUCC_计算机网络实验_实验04 VLAN配置
浙江大学城市学院实验报告文件下载 1.CSDN 2.百度网盘,提取码: vrvq 一.实验目的掌握交换机VLAN的配置. 二.实验内容用Packet Tracer模拟器建立网络,进行单交换机VL ...
python第六周实验_第六周实验四
二.实验的内容 (1)根据下面的要求实现圆类Circle. 1.圆类Circle的成员变量:radius表示圆的半径. 2.圆类Circle的方法成员: Circle():构造方法,将半径置0 Cir ...
中国大学MOOC数据库系统概论中国人民大学实验三触发器
实验题基于学生选课数据库,其包含三个关系模式: (1)学生关系模式Student(Sno, Sname, Ssex, Sage,Sdept) (2)课程关系模式Course(Cno, Cname, C ...
ZUCC_计算机网络实验_实验01 实验一RJ45原理与制作
浙江大学城市学院实验报告一.实验目的掌握网线制作和测试方法,了解标准568A与568B网线的线序,掌握直通双绞线和交叉双绞线的做法. 二.实验内容 1.直通双绞线的制作 2.交叉双绞线的制作 3. ...
ZUCC_计算机网络实验_实验03 交换机基本配置
浙江大学城市学院实验报告文件下载: 1.CSDN 2.百度网盘,提取码: c8f7 一.实验目的熟悉交换机的工模式在Packet Tracer模拟器中练习交换机CLI基本配置区分交换机与集线器 ...
ZUCC_大数据计算技术_实验三 HDFS编程实践
实验三 HDFS编程实践课程名称大数据计算技术实验项目名称实验三 HDFS编程实践启动hadoop 一.利用Shell命令与HDFS进行交互 1. 目录操作新建家目录可以看到新建目录内无 ...
ZUCC_操作系统原理实验_实验九消息队列
操作系统原理实验报告课程名称操作系统原理实验实验项目名称实验九消息队列实验目的了解 Linux 系统的进程间通信机构 (IPC): 理解Linux 关于消息队列的概念: 掌握 Linux ...

ZUCC_数据库系统概论实验_实验六 JDBC进阶 3

实验6

相关知识点

实验目的：

实验内容：

利用批量SQL语句执行的方法实现实验5中的最后两个方法：

编写批量借阅读书函数： public void lendbooks(String readerId,Collection barcodes) … 。其中第二个参数为图书条码集合。

编写批量设置罚金函数：public void setPenalSum(String readerId,Map<String,Double> penalSums) … 。其中第二个参数的key为barcode，value为改读者尚未归还图书的罚金（注意，不要设置已经归还图书的罚金）。

模仿SystemUserDAO类，实现BookDAO类，并改造BookManager类，使之通过BookDAO操作数据库。

给出BookDAO类代码。

给出改造后BookManager类的各个方法的代码。

在BaseDAO中，增加方法，实现根据主码提取对象的方法load。

写出函数代码

ZUCC_数据库系统概论实验_实验六 JDBC进阶 3相关推荐

最新文章

热门文章