人員管理程序講解學(xué)習(xí)

1、精品文檔1 ) package org.lxh.useradmin.dao;import java.util.List;import org.lxh.useradmin.vo.User;public interface IUserDAO /* 表示數(shù)據(jù)庫的增加操作*param userreturnthrows Exception*/public boolean doCreate(User user) throws Exception;public boolean doUpdate(User user) throws Exception;/* 表示刪除操作，按編號刪除*param idretur

2、nthrows Exception*/public boolean doDelete(int id) throws Exception;/*表示數(shù)據(jù)庫的查詢操作param idreturnthrows Exception*/public User findById(int id) throws Exception;/*查詢的時(shí)候?qū)⒎祷匾唤M對象param keyWordreturnthrows Exception*/public List<User> findAll(String keyWord) throws Exception; 精品文檔精品文檔(2) package org.l

3、xh.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 IUserDAOIm

4、pl 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;S

5、tring sql = "INSERT INTO user(name,sex,birthday) V ALUES (?,?,?) " try pstmt = this.conn.prepareStatement(sql);pstmt.setString(1, user.getName();/ 所有的內(nèi)容從 user類中取出pstmt.setString(2, user.getSex();/ 所有的內(nèi)容從 user類中取出 pstmt.setDate(3, new java.sql.Date(user.getBirthday().getTime();if (pstmt.exe

6、cuteUpdate() > 0) / 至少已經(jīng)更新了一行 flag = true; catch (Exception e) throw e; finally / 不管如何拋出，最終肯定是要進(jìn)行數(shù)據(jù)庫的關(guān)閉操作的if (pstmt != null) try pstmt.close(); catch (Exception e1) 精品文檔精品文檔 this.dbc.close(); return flag;Overridepublic boolean doDelete(int id) throws Exception boolean flag = false;PreparedStateme

7、nt pstmt = null;String sql = "DELETE FROM user WHERE id=? "try pstmt = this.conn.prepareStatement(sql);pstmt.setInt(1, id); / 所有的內(nèi)容從user 類中取出if (pstmt.executeUpdate() > 0) / 至少已經(jīng)更新了一行 flag = true; catch (Exception e) throw e; finally / 不管如何拋出，最終肯定是要進(jìn)行數(shù)據(jù)庫的關(guān)閉操作的if (pstmt != null) try pstm

8、t.close(); catch (Exception e1) this.dbc.close(); return flag;Overridepublic boolean doUpdate(User user) throws Exception boolean flag = false;PreparedStatement pstmt = null;String sql = "UPDA TE user SET name=?,sex=?,birthday=? WHERE id=?" try pstmt = this.conn.prepareStatement(sql);pstmt

9、.setString(1, user.getName();/ 所有的內(nèi)容從 user類中取出pstmt.setString(2, user.getSex();/ 所有的內(nèi)容從 user類中取出pstmt.setDate(3, new java.sql.Date(user.getBirthday().getTime();pstmt.setInt(4, user.getId();if (pstmt.executeUpdate() > 0) / 至少已經(jīng)更新了一行精品文檔精品文檔flag = true; catch (Exception e) throw e; finally / 不管如何拋出

10、，最終肯定是要進(jìn)行數(shù)據(jù)庫的關(guān)閉操作的if (pstmt != null) try pstmt.close(); catch (Exception e1) this.dbc.close();return flag;Overridepublic List<User> findAll(String keyWord) throws Exception List<User> all = new ArrayList<User>();PreparedStatement pstmt = null;String sql = "SELECT id,name,sex,b

11、irthday 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 + "%");Re

12、sultSet rs = pstmt.executeQuery(); / 執(zhí)行查詢操作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); / 所有的內(nèi)容向集合中插入rs.close() ; catch (Exception e) throw e; finally / 不管如何拋出，最終肯定是要進(jìn)行數(shù)據(jù)庫的關(guān)閉操作的i

13、f (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.prepar

14、eStatement(sql);pstmt.setInt(1, id) ;ResultSet rs = pstmt.executeQuery(); / 執(zhí)行查詢操作 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 / 不管如何拋出，最終肯定是要進(jìn)行數(shù)據(jù)庫的關(guān)閉

15、操作的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

16、.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.forNam

17、e(DBDRIVER) ; catch (ClassNotFoundException e) / TODO Auto-generated catch block e.printStackTrace();try conn = DriverManager.getConnection(DBURL, DBUSER,DBPASS) ; catch (SQLException e) / TODO Auto-generated catch block e.printStackTrace();public Connection getConnection() return this.conn ;public

18、void close()if(this.conn!=null)try this.conn.close() ; catch (SQLException e) / TODO Auto-generated catch block e.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

19、 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&l

20、t;User> allUser = DAOFactory.getIUserDAOInstance().findAll("") ;Iterator<User> 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

21、 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 = DAOFa

22、ctory.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();use

23、r.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().doUpdate(user);(6) DROP TABLE user ;CR