carddao.java

这个是j2eejava web 编程精要十五讲的全部源码。对学习java web编程的人来说是很能得的资料

package card;

import java.sql.*;
import java.util.ArrayList;
import card.CardBean;
import util.*;
import java.text.SimpleDateFormat;

public class CardDAO {
    public CardDAO() {
    }
    static Connection dbConn,conn;
     static PreparedStatement ps,ps1;
     static ResultSet rs,rs1;
     static ArrayList arr;

       //把名片数据插入数据表中

        public static boolean insert(ArrayList list) {
            boolean bo = false;

         try {

             conn = DBPool.getConnection();
             System.out.println("Location is after getConnection()!!!");
             System.out.println("Begin!");
             String sql = "insert into t_card(name,sex,title,mobile,phone,email,address) values(?,?,?,?,?,?,?)";
             System.out.println(sql);
             ps = conn.prepareStatement(sql);
         //ps.setString(1, (String)list.get(0));
         System.out.println("Start now!"+(String)list.get(0) );
         ps.setString(1, (String)list.get(0));
         //System.out.println("(String)list.get(0) "+(String)list.get(0));
         ps.setString(2, (String)list.get(1));
         //System.out.println("(String)list.get(1) "+(String)list.get(1));
          ps.setString(3, (String)list.get(2));
          //System.out.println("(String)list.get(2) "+(String)list.get(2));
           ps.setString(4, (String)list.get(3));
           //System.out.println("(String)list.get(3) "+(String)list.get(3));
            ps.setString(5, (String)list.get(4));
            //System.out.println("(String)list.get(4) "+(String)list.get(4));
             ps.setString(6, (String)list.get(5));
             ps.setString(7, (String)list.get(6));

          ps.executeUpdate();
          System.out.println("Data has Inserted!");
          ps.close();
          conn.close();

          bo= true;

         } catch(Exception e) {
           //  bo = false;
             System.out.println(e);}
        // finally {
          //   try {
//              ps.close();
            //     conn.close();
            // }catch (SQLException e) {System.out.println(e);}
         //}
         return bo;
     }


       // 从数据库取出card信息

        public static ArrayList getCard(PageBean pageBean){

          System.out.println("getProduct() begins!!");

          int pageNum = pageBean.getPageNum();  //得到每页显示的记录数
            int currPage = pageBean.getCurrPage(); //得到当前页数
            String condition = pageBean.getCondition();  //得到查询条件

            int start = currPage * pageNum;  //当前页的开始记录
            int end = start + pageNum;  //当前页的结束记录

            String sql, sql1;

            if(condition.equals("")) {
                sql1="select count(*) from t_card where flag='0'";
                sql="select * from t_card where flag='0'";
            }
            else {
               sql1="select count(*) from t_card where flag='0' and name like '%"+condition+"%'";
                sql="select * from t_card where flag='0' and (name like '%"+condition+"%' or mobile like '%"+condition+"%'"
                    +"or phone like '%"+condition+"%' or email like '%"+condition+"%'"
                    +"or address like '%"+condition+"%')";
            }

           ArrayList result = new ArrayList();

            try {
                conn = DBPool.getConnection();
                System.out.println("getConnection() end!!");



                //获得数据表中的记录总数
                ps1 = conn.prepareStatement(sql1);
                rs1 = ps1.executeQuery();
               while (rs1.next())
                 PageBean.setRecordNum(rs1.getInt(1));
                rs1.close();
                ps1.close();
                //////////////////////////////

                //String sql = "select * from t_product_info";
                ps = conn.prepareStatement(sql);
                System.out.println("ps execute!!");
                rs = ps.executeQuery();
                System.out.println("rs get!!");

                int rowNum = 1;

              while(rs.next()){

                   if ((rowNum > start) && (rowNum <= end)) {

                       CardBean info = new CardBean();

                       info.setCardID(rs.getInt(1));
                       info.setName(rs.getString(2));
                       info.setSex(rs.getString(3));
                       info.setTitle(rs.getString(4));
                       info.setMobile(rs.getString(5));
                       info.setPhone(rs.getString(6));
                       info.setEmail(rs.getString(7));
                       info.setAddress(rs.getString(8));

                       result.add(info);
                   }
                  rowNum++;
              }

              PageBean.setRecordNum(rowNum);  //把

                  rs.close();
                  ps.close();
                  conn.close();

              System.out.println("Successful to get query data from db!!");

            } catch (Exception e) {
              System.out.println(e.getMessage());
            }

            return result;
          }

          // 从数据库取出Card信息

           public static CardBean getCard(String cardID){

             CardBean info = new CardBean();

               try {
                conn = DBPool.getConnection();
                System.out.println("getConnection() end!!");
               ps = conn.prepareStatement("select * from t_card where card_id=?");
               ps.setString(1,cardID);
               System.out.println("ps execute!!");
               rs = ps.executeQuery();
               System.out.println("rs get!!");

                 while(rs.next()){

                     //ProductBean info = new ProductBean();

                     info.setCardID(rs.getInt(1));
                     info.setName(rs.getString(2));
                     info.setSex(rs.getString(3));
                    info.setTitle(rs.getString(4));
                    info.setMobile(rs.getString(5));
                   info.setPhone(rs.getString(6));
                   info.setEmail(rs.getString(7));
                   info.setAddress(rs.getString(8));

                 }
                     rs.close();
                     ps.close();
                     conn.close();

                 System.out.println("Successful to get query data from db!!");

               } catch (Exception e) {
                 System.out.println(e.getMessage());
               }

               return info;
             }

             //删除名片信息

          public static boolean delCard(String cardID)
          {
                 boolean bool = false;
            // connect to the database
              try {
              conn = DBPool.getConnection();
              System.out.println("Here is DAO. Successful to connect to DB!!!");

              String sqlDel = "delete from t_card where card_id=?";
              ps = conn.prepareStatement(sqlDel);
              ps.setInt(1, Integer.parseInt(cardID));
              ps.executeUpdate();

              ps.close();
              conn.close();
              bool = true;
            } catch (Exception e) {
                System.out.println(e.getMessage());
              }
              return bool;
          }

          //更新Card信息

          public static boolean updateCard(ArrayList list)
          {
              boolean bool = false;

            try {

                conn = DBPool.getConnection();
                System.out.println("Here is DAO. Successful to connect to DB!!!");

                String sqlUp = "UPDATE t_card SET  name = '" + ((String)list.get(0)).trim()
                     +"',sex  = '" + ((String)list.get(1)).trim()
                    + "', title = '" + ((String)list.get(2)).trim()
                     + "', mobile = '" + ((String)list.get(3)).trim()
                     + "', phone = '" + ((String)list.get(4)).trim()
                     + "', email = '" + ((String)list.get(5)).trim()
                     + "', address = '" + ((String)list.get(6)).trim()

                    + "' WHERE card_id = ?";
                //System.out.println(sqlUp);
                   ps = conn.prepareStatement(sqlUp);
                    ps.setInt(1,Integer.parseInt((String)list.get(7)));
                      System.out.println(sqlUp);
                    ps.executeUpdate();

                System.out.println("here is CardDAO.updateCard().psUp pass!");

               ps.close();
               conn.close();
               bool = true;

                 } catch(Exception e)
              {
                System.out.println(e);
              }
              return bool;
          }

          //移到回收站

           public static boolean retrieve(String cardID)
           {
               boolean bool = false;

             try {

                 conn = DBPool.getConnection();
                 System.out.println("Here is DAO. Successful to connect to DB!!!");

                 String sqlUp = "UPDATE t_card SET  flag = '" + 1


                     + "' WHERE card_id = ?";
                 //System.out.println(sqlUp);
                    ps = conn.prepareStatement(sqlUp);
                     ps.setInt(1,Integer.parseInt(cardID));
                       System.out.println(sqlUp);
                     ps.executeUpdate();

                // System.out.println("here is CardDAO.updateCard().psUp pass!");

                ps.close();
                conn.close();
                bool = true;

                  } catch(Exception e)
               {
                 System.out.println(e);
               }
               return bool;
           }

           //还原

            public static boolean revert(String cardID)
            {
                boolean bool = false;

              try {

                  conn = DBPool.getConnection();
                  System.out.println("Here is DAO. Successful to connect to DB!!!");

                  String sqlUp = "UPDATE t_card SET  flag = '" + 0


                      + "' WHERE card_id = ?";
                  //System.out.println(sqlUp);
                     ps = conn.prepareStatement(sqlUp);
                      ps.setInt(1,Integer.parseInt(cardID));
                        System.out.println(sqlUp);
                      ps.executeUpdate();

                 // System.out.println("here is CardDAO.updateCard().psUp pass!");

                 ps.close();
                 conn.close();
                 bool = true;

                   } catch(Exception e)
                {
                  System.out.println(e);
                }
                return bool;
            }



           // 取出回收站信息

              public static ArrayList getRetrieve(PageBean pageBean){

                System.out.println("getProduct() begins!!");

                int pageNum = pageBean.getPageNum();  //得到每页显示的记录数
                  int currPage = pageBean.getCurrPage(); //得到当前页数
                  String condition = pageBean.getCondition();  //得到查询条件

                  int start = currPage * pageNum;  //当前页的开始记录
                  int end = start + pageNum;  //当前页的结束记录

                  String sql, sql1;

                  if(condition.equals("")) {
                      sql1="select count(*) from t_card where flag='1'";
                      sql="select * from t_card where flag='1'";
                  }
                  else {
                     sql1="select count(*) from t_card where flag='1' and name like '%"+condition+"%'";
                     sql="select * from t_card where flag='1' and (name like '%"+condition+"%' or mobile like '%"+condition+"%'"
                   +"or phone like '%"+condition+"%' or email like '%"+condition+"%'"
                   +"or address like '%"+condition+"%')";
                  }

                 ArrayList result = new ArrayList();

                  try {
                      conn = DBPool.getConnection();
                      System.out.println("getConnection() end!!");



                      //获得数据表中的记录总数
                      ps1 = conn.prepareStatement(sql1);
                      rs1 = ps1.executeQuery();
                     while (rs1.next())
                       PageBean.setRecordNum(rs1.getInt(1));
                      rs1.close();
                      ps1.close();
                      //////////////////////////////

                      //String sql = "select * from t_product_info";
                      ps = conn.prepareStatement(sql);
                      System.out.println("ps execute!!");
                      rs = ps.executeQuery();
                      System.out.println("rs get!!");

                      int rowNum = 1;

                    while(rs.next()){

                         if ((rowNum > start) && (rowNum <= end)) {

                             CardBean info = new CardBean();

                             info.setCardID(rs.getInt(1));
                             info.setName(rs.getString(2));
                             info.setSex(rs.getString(3));
                             info.setTitle(rs.getString(4));
                             info.setMobile(rs.getString(5));
                             info.setPhone(rs.getString(6));
                             info.setEmail(rs.getString(7));
                             info.setAddress(rs.getString(8));

                             result.add(info);
                         }
                        rowNum++;
                    }

                    PageBean.setRecordNum(rowNum);

                        rs.close();
                        ps.close();
                        conn.close();

                    System.out.println("Successful to get query data from db!!");

                  } catch (Exception e) {
                    System.out.println(e.getMessage());
                  }

                  return result;
                }



   }