customerdao.java

一个基于java工厂模式的 的实现

/*
 * CustomerDAO.java
 *
 * Created on 2007年4月18日, 下午1:19
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package com.ebuy.dataaccess;

import com.ebuy.entities.CustomerEntity;
import java.awt.GradientPaint;
import java.sql.SQLException;

/**
 *
 * @author Administrator
 */
public class CustomerDAO extends DAOAdapter
{
    
    /** Creates a new instance of CustomerDAO */
    public CustomerDAO()
    {
    }
    public boolean addEntity(Object entity)
    {
        CustomerEntity c=(CustomerEntity)entity;
        String sp="Customers_Insert(?,?,?,?,?,?,?,?)";
        try
        {
            java.sql.CallableStatement csmt=this.server.getCallableStatement(sp);
            csmt.setString(1,c.getLoginname());
            csmt.setString(2,c.getLoginkey());
            csmt.setString(3,c.getRealname());
            csmt.setString(4,c.getBilladdress());
            csmt.setString(5,c.getEmail());
            csmt.setString(6,c.getMobile());
            csmt.setInt(7,c.getGrade());
            csmt.registerOutParameter(8,java.sql.Types.INTEGER);
            csmt.executeUpdate();
            int id=csmt.getInt(8);
            return (id!=0);
        }
        catch (SQLException ex)
        {
            ExceptionManager.handlerException(ex);
            return false;
        }
        finally
        {
            this.server.closeConnection();
        }
    }
    public Object findByPK(Object... pk)
    {
        String sp="Customers_Login(?,?,?,?,?,?,?,?)";
        String loginname=pk[0].toString();
        String loginkey=pk[1].toString();
        try
        {
            java.sql.CallableStatement csmt=this.server.getCallableStatement(sp);
            csmt.setString(1,loginname);
            csmt.setString(2,loginkey);
            csmt.registerOutParameter(3,java.sql.Types.INTEGER);
            csmt.registerOutParameter(4,java.sql.Types.VARCHAR);
            csmt.registerOutParameter(5,java.sql.Types.VARCHAR);
            csmt.registerOutParameter(6,java.sql.Types.VARCHAR);
            csmt.registerOutParameter(7,java.sql.Types.VARCHAR);
            csmt.registerOutParameter(8,java.sql.Types.INTEGER);
            csmt.execute();
            int id=csmt.getInt(3);
            String realname=csmt.getString(4);
            String billaddress=csmt.getString(5);
            String email=csmt.getString(6);
            String mobile=csmt.getString(7);
            int grade=csmt.getInt(8);
            if(id!=0)
            {
                CustomerEntity c=new CustomerEntity();
                c.setCustomerid(id);
                c.setLoginname(loginname);
                c.setLoginkey(loginkey);
                c.setRealname(realname);
                c.setBilladdress(billaddress);
                c.setMobile(mobile);
                c.setEmail(email);
                c.setGrade(grade);
                return c;
            }
            else
            {
                return null;
            }
        } 
        catch (SQLException ex)
        {
           ExceptionManager.handlerException(ex);
           return null;
        }
        finally
        {
            this.server.closeConnection();
        }
    }
}