




已阅读5页,还剩6页未读, 继续免费阅读
版权说明:本文档由用户提供并上传,收益归属内容提供方,若内容存在侵权,请进行举报或认领
文档简介
(1)package org.lxh.useradmin.dao;import java.util.List;import org.lxh.useradmin.vo.User;public interface IUserDAO /* * 表示数据库的增加操作 * * param user * return * throws Exception */public boolean doCreate(User user) throws Exception;public boolean doUpdate(User user) throws Exception;/* * 表示删除操作,按编号删除 * * param id * return * throws Exception */public boolean doDelete(int id) throws Exception;/* * 表示数据库的查询操作 * param id * return * throws Exception */public User findById(int id) throws Exception;/* * 查询的时候将返回一组对象 * param keyWord * return * throws Exception */public List findAll(String keyWord) throws Exception;(2)package org.lxh.useradmin.dao.impl;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.util.ArrayList;import java.util.List;import org.lxh.useradmin.dao.IUserDAO;import org.lxh.useradmin.dbc.DataBaseConnection;import org.lxh.useradmin.vo.User;public class IUserDAOImpl implements IUserDAO private DataBaseConnection dbc = null;private Connection conn = null;public IUserDAOImpl() this.dbc = new DataBaseConnection();this.conn = this.dbc.getConnection();Overridepublic boolean doCreate(User user) throws Exception boolean flag = false;PreparedStatement pstmt = null;String sql = INSERT INTO user(name,sex,birthday) VALUES (?,?,?) ;try pstmt = this.conn.prepareStatement(sql);pstmt.setString(1, user.getName(); / 所有的内容从user类中取出pstmt.setString(2, user.getSex(); / 所有的内容从user类中取出pstmt.setDate(3, new java.sql.Date(user.getBirthday().getTime();if (pstmt.executeUpdate() 0) / 至少已经更新了一行flag = true; catch (Exception e) throw e; finally / 不管如何抛出,最终肯定是要进行数据库的关闭操作的if (pstmt != null) try pstmt.close(); catch (Exception e1) this.dbc.close();return flag;Overridepublic boolean doDelete(int id) throws Exception boolean flag = false;PreparedStatement pstmt = null;String sql = DELETE FROM user WHERE id=? ;try pstmt = this.conn.prepareStatement(sql);pstmt.setInt(1, id); / 所有的内容从user类中取出if (pstmt.executeUpdate() 0) / 至少已经更新了一行flag = true; catch (Exception e) throw e; finally / 不管如何抛出,最终肯定是要进行数据库的关闭操作的if (pstmt != null) try pstmt.close(); catch (Exception e1) this.dbc.close();return flag;Overridepublic boolean doUpdate(User user) throws Exception boolean flag = false;PreparedStatement pstmt = null;String sql = UPDATE user SET name=?,sex=?,birthday=? WHERE id=?;try pstmt = this.conn.prepareStatement(sql);pstmt.setString(1, user.getName(); / 所有的内容从user类中取出pstmt.setString(2, user.getSex(); / 所有的内容从user类中取出pstmt.setDate(3, new java.sql.Date(user.getBirthday().getTime();pstmt.setInt(4, user.getId();if (pstmt.executeUpdate() 0) / 至少已经更新了一行flag = true; catch (Exception e) throw e; finally / 不管如何抛出,最终肯定是要进行数据库的关闭操作的if (pstmt != null) try pstmt.close(); catch (Exception e1) this.dbc.close();return flag;Overridepublic List findAll(String keyWord) throws Exception List all = new ArrayList();PreparedStatement pstmt = null;String sql = SELECT id,name,sex,birthday FROM user WHERE name LIKE ? OR sex LIKE ? OR birthday LIKE ?;try pstmt = this.conn.prepareStatement(sql);pstmt.setString(1, % + keyWord + %);pstmt.setString(2, % + keyWord + %);pstmt.setString(3, % + keyWord + %);ResultSet rs = pstmt.executeQuery(); / 执行查询操作while (rs.next() User user = new User();user.setId(rs.getInt(1);user.setName(rs.getString(2);user.setSex(rs.getString(3);user.setBirthday(rs.getDate(4);all.add(user); / 所有的内容向集合中插入rs.close() ; catch (Exception e) throw e; finally / 不管如何抛出,最终肯定是要进行数据库的关闭操作的if (pstmt != null) try pstmt.close(); catch (Exception e1) this.dbc.close();return all;Overridepublic User findById(int id) throws Exception User user = null ;PreparedStatement pstmt = null;String sql = SELECT id,name,sex,birthday FROM user WHERE id=?;try pstmt = this.conn.prepareStatement(sql);pstmt.setInt(1, id) ;ResultSet rs = pstmt.executeQuery(); / 执行查询操作if (rs.next() user = new User();user.setId(rs.getInt(1);user.setName(rs.getString(2);user.setSex(rs.getString(3);user.setBirthday(rs.getDate(4);rs.close() ; catch (Exception e) throw e; finally / 不管如何抛出,最终肯定是要进行数据库的关闭操作的if (pstmt != null) try pstmt.close(); catch (Exception e1) this.dbc.close();return user;(3)package org.lxh.useradmin.dbc;import java.sql.Connection;import java.sql.DriverManager;import java.sql.SQLException;public class DataBaseConnection private static final String DBDRIVER = org.gjt.mm.mysql.Driver ;private static final String DBURL = jdbc:mysql:/localhost:3306/mldn ;private static final String DBUSER = root ;private static final String DBPASS = mysqladmin ;private Connection conn = null ;public DataBaseConnection()try Class.forName(DBDRIVER) ; catch (ClassNotFoundException e) / TODO Auto-generated catch blocke.printStackTrace();try conn = DriverManager.getConnection(DBURL, DBUSER,DBPASS) ; catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();public Connection getConnection()return this.conn ;public void close()if(this.conn!=null)try this.conn.close() ; catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();(4)package org.lxh.useradmin.factory;import org.lxh.useradmin.dao.IUserDAO;import org.lxh.useradmin.dao.impl.IUserDAOImpl;public class DAOFactory public static IUserDAO getIUserDAOInstance()return new IUserDAOImpl() ;(5)package org.lxh.useradmin.test;import java.util.Iterator;import java.util.List;import org.lxh.useradmin.factory.DAOFactory;import org.lxh.useradmin.vo.User;public class TestAll public static void main(String args) throws Exception List allUser = DAOFactory.getIUserDAOInstance().findAll() ;Iterator iter = allUser.iterator() ;while(iter.hasNext()User user = iter.next() ;System.out.println(user);package org.lxh.useradmin.test;import org.lxh.useradmin.factory.DAOFactory;public class TestDelete public static void main(String args) throws Exception DAOFactory.getIUserDAOInstance().doDelete(2);package org.lxh.useradmin.test;import org.lxh.useradmin.factory.DAOFactory;import org.lxh.useradmin.vo.User;public class TestId public static void main(String args) throws Exception User user = DAOFactory.getIUserDAOInstance().findById(1) ;System.out.println(user);package org.lxh.useradmin.test;import java.util.Date;import org.lxh.useradmin.factory.DAOFactory;import org.lxh.useradmin.vo.User;public class TestInsert public static void main(String args) throws Exception User user = new User();user.setName(李兴华);user.setSex(男);user.setBirthday(new Date();DAOFactory.getIUserDAOInstance().doCreate(user);package org.lxh.useradmin.test;import java.util.Date;import org.lxh.useradmin.factory.DAOFactory;import org.lxh.useradmin.vo.User;public class TestUpdate public static void main(String args) throws Exception User user = new User();user.setName(张心);user.setSex(女);user.setId(2) ;user.setBirthday(new Date();DAOFactory.getIUserDAOInstance().do
温馨提示
- 1. 本站所有资源如无特殊说明,都需要本地电脑安装OFFICE2007和PDF阅读器。图纸软件为CAD,CAXA,PROE,UG,SolidWorks等.压缩文件请下载最新的WinRAR软件解压。
- 2. 本站的文档不包含任何第三方提供的附件图纸等,如果需要附件,请联系上传者。文件的所有权益归上传用户所有。
- 3. 本站RAR压缩包中若带图纸,网页内容里面会有图纸预览,若没有图纸预览就没有图纸。
- 4. 未经权益所有人同意不得将文件中的内容挪作商业或盈利用途。
- 5. 人人文库网仅提供信息存储空间,仅对用户上传内容的表现方式做保护处理,对用户上传分享的文档内容本身不做任何修改或编辑,并不能对任何下载内容负责。
- 6. 下载文件中如有侵权或不适当内容,请与我们联系,我们立即纠正。
- 7. 本站不保证下载资源的准确性、安全性和完整性, 同时也不承担用户因使用这些下载资源对自己和他人造成任何形式的伤害或损失。
最新文档
- 金堂县应急预案管理办法
- 餐饮店立夏营销活动方案
- 房地产项目管理人员保密合同与项目进度保障协议
- 工程咨询集团组建方案
- 大型桥梁建设盘扣式脚手架施工与验收合同
- 离婚时夫妻共同财产清算及个人财产保护协议范本
- 装修工程消防通道改造与物业应急通道管理合同
- 离婚协议中住房安置补充协议范本精简版
- 跨境电商零售进口市场规模分析报告:2025年市场增长与机遇
- 跨境电商零售进口市场规模与跨境电商消费者购买行为分析报告
- 2025年国家网络安全宣传周知识竞赛题库(试题及答案)
- 《论教育》主要篇目课件
- 防止滑倒摔伤事故的安全培训
- JJG 707-2003扭矩扳子
- GB/T 26562-2011自行式坐驾工业车辆踏板的结构与布置踏板的结构与布置原则
- GB/T 11718-2021中密度纤维板
- 商务英语情景对话100主题(迅速提高口语)
- 《高频电子线路》课后答案-曾兴雯版高等教育出版社
- 《舞蹈艺术赏析》课件
- PLC项目实操练习题
- 《新能源材料与器件》教学课件-04电化学能源材料与器件
评论
0/150
提交评论