memberdao.java

java三层架构（MVC)实现的在线图书销售系统。其中应用到工厂

package accp.yyw.model.dao;

/**
 * <p>Title: BookShop</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: accp</p>
 * @author yyw
 * @version 1.0
 */

import java.sql.*;
import java.util.*;

import accp.yyw.model.bean.*;

public class MemberDAO implements Idao{

    private Connection connection = null;

    private PreparedStatement insertps = null;
    private PreparedStatement deleteps = null;
    private PreparedStatement updateps = null;
    private PreparedStatement selectps = null;

    private String insert = "INSERT INTO Members(memberName,mPassword,mProblem,mAnswer,mName,mSex,mPapers,mProfession,mBirthdate,mCulture,mArea,mPostcode,mTelephone,mAddress,mEmail) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
    private String delete = "delete from Members where memberId=?";
    private String update = "update Members set memberName=?,mPassword=?,mProblem=?,mAnswer=?,mName=?,mSex=?,mPapers=?,mProfession=?,mBirthdate=?,mCulture=?,mArea=?mPostcode=?,mTelephone=?,mAddress=?,mEmail=? where memberId=?";
    private String select = "select * from Members";

    public MemberDAO(Connection connection){

            this.connection = connection;

            try{

                    insertps = connection.prepareStatement(insert);
                    deleteps = connection.prepareStatement(delete);
                    updateps = connection.prepareStatement(update);
                    selectps = connection.prepareStatement(select);
            }
            catch(SQLException sqle){
                    System.out.println("error in initMemberDao:\n");
                    System.out.println(sqle);
            }
    }

    public boolean insertObject(Object o){

            MemberVo memberbean = (MemberVo)o;

            int bli = 0;

            try{

                    synchronized(insertps) {

                            insertps.clearParameters();

                            insertps.setString(1,memberbean.getMembername());
                            insertps.setString(2,memberbean.getPassword());
                            insertps.setString(3,memberbean.getProblem());
                            insertps.setString(4,memberbean.getAnswer());
                            insertps.setString(5,memberbean.getName());
                            insertps.setString(6,memberbean.getSex());
                            insertps.setString(7,memberbean.getPapernumber());
                            insertps.setString(8,memberbean.getProfession());
                            insertps.setString(9,memberbean.getBirthdate());
                            insertps.setString(10,memberbean.getCulture());
                            insertps.setString(11,memberbean.getArea());
                            insertps.setString(12,memberbean.getPostcode());
                            insertps.setString(13,memberbean.getTelephone());
                            insertps.setString(14,memberbean.getAddress());
                            insertps.setString(15,memberbean.getEmail());

                            bli = insertps.executeUpdate();
                    }
            }
            catch(SQLException sqle){

                    System.out.println(sqle);
            }

            return bli==1?true:false;
    }

    public boolean deleteObject(Object o){

            return true;
    }

    public boolean updateObject(Object o){

            return true;
    }

    public boolean selectObject(Object o){

            return true;
    }

    public List getAllObject(Object o){

            String memberquery = "";

            List list = new ArrayList();

            try {

                      Statement stmt = connection.createStatement();
                      ResultSet rs = stmt.executeQuery(memberquery);

                      while (rs.next()) {

                        MemberVo memberbean = new MemberVo();

                        memberbean.setMembername(rs.getString("memberName"));
                        memberbean.setPassword(rs.getString("mPassword"));

                        list.add(memberbean);
                      }
            }
            catch(SQLException sqle) {

                System.out.println("This is getMemberData Exception in MemberDAO:");
                System.out.println(sqle);
            }
            catch(Exception e) {

                       System.out.println("This is getMemberData unknown Exception in MemberDAO :");
                       System.out.println(e);
            }

            return list;
          }

    public Object getSingleObject(Object o){

            MemberVo memberbean = new MemberVo();

            return memberbean;
    }
 }