图书馆管理系统数据库的连接与实现.doc

3、 实验步骤1、 程序源代码-BaseDao.java的代码package data;import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;/* * 类BaseDao用于设置连接数据库的相关信息和基本操作 * * author raymond */public class BaseDao protected static String driver = org.apache.derby.jdbc.ClientDriver; / 数据库驱动（将derbyclient.jar文件加载到项目库里） protected static String url = jdbc:derby:/localhost:1527/mylibrary; / 连接url，连接数据库之前，先要启动数据库服务器 protected static String dbUser = raymond; / 数据库用户名 protected static String dbPwd = 88888888; / 数据库密码 private static Connection conn = null; / 构造方法，创建数据库连接 private BaseDao() try if (conn = null) Class.forName(driver); / 加载数据库驱动 conn = DriverManager.getConnection(url, dbUser, dbPwd); / 建立数据库连接 / else /return; / catch (Exception e) System.out.println(e.getMessage(); / 执行数据库查询操作 public static ResultSet executeQuery(String sql) try if (conn = null) new BaseDao(); return conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE).executeQuery(sql); / 执行数据库查询 catch (SQLException e) System.out.println(e.getMessage(); return null; / 执行数据库更新操作 public static int executeUpdate(String sql) try if (conn = null) new BaseDao(); return conn.createStatement().executeUpdate(sql); / 执行数据库更新 catch (SQLException e) System.out.println(e.getMessage(); return -1; finally public static void close() try conn.close(); catch (SQLException e) System.out.println(e.getMessage(); finally conn = null; -BookDao.java的代码package data;import entity.Book;import java.sql.ResultSet;import java.util.ArrayList;import java.util.List;/* * 类BookDao用于图书查询的操作 * * author raymond */public class BookDao /根据图书编号，获得单个图书实体 public static Book selectBook(String id) String sql = select * from book where id= + id + ; ResultSet rs = BaseDao.executeQuery(sql); Book book = null; try if (rs.next() book = new Book(); book.setId(rs.getString(id); book.setType(rs.getString(type); book.setName(rs.getString(name); book.setAuthor(rs.getString(author); book.setTranslator(rs.getString(translator); book.setPublisher(rs.getString(publisher); book.setPublish_time(rs.getDate(publish_time); book.setPrice(rs.getDouble(price); book.setStock(rs.getInt(stock); catch (Exception e) System.out.println(e.getMessage(); BaseDao.close(); return book; /获得满足sql语句的图书实体列表 public static List selectBookList(String sql) List list = new ArrayList(); ResultSet rs = BaseDao.executeQuery(sql); try while (rs.next() Book book = new Book(); book.setId(rs.getString(id); book.setType(rs.getString(type); book.setName(rs.getString(name); book.setAuthor(rs.getString(author); book.setTranslator(rs.getString(translator); book.setPublisher(rs.getString(publisher); book.setPublish_time(rs.getDate(publish_time); book.setPrice(rs.getDouble(price); book.setStock(rs.getInt(stock); list.add(book); catch (Exception e) System.out.println(e.getMessage(); BaseDao.close(); return list; -BaseDao.java的代码package data;import entity.Reader;import java.sql.ResultSet;import java.util.ArrayList;import java.util.List;/* * 类BaseDao用于读者查询的操作 * * author raymond */public class ReaderDao /根据读者编号，获得单个读者实体 public static Reader selectReader(String id) String sql = select * from reader where id= + id; ResultSet rs = BaseDao.executeQuery(sql); Reader reader = null; try if (rs.next() reader = new Reader(); reader.setId(rs.getString(id); reader.setType(rs.getString(type); reader.setName(rs.getString(name); reader.setSex(rs.getString(sex); reader.setMax_num(rs.getString(max_num); reader.setDays_num(rs.getInt(days_num); catch (Exception e) System.out.println(e.getMessage(); BaseDao.close(); return reader; /获得满足sql语句的读者实体列表 public static List selectReaderList(String sql) List list = new ArrayList(); ResultSet rs = BaseDao.executeQuery(sql); Reader reader = null; try while (rs.next() reader = new Reader(); reader.setId(rs.getString(id); reader.setType(rs.getString(type); reader.setName(rs.getString(name); reader.setSex(rs.getString(sex); reader.setMax_num(rs.getString(max_num); reader.setDays_num(rs.getInt(days_num); list.add(reader); catch (Exception e) Syst