voiceuserdao.java

采用JAVA开发

package com.gctech.sms.voice.dao;

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

  /* author:[e-mail] */
  public class VoiceUserDAO { 
      //-----Codes below generated by dao 

    public int insert(Connection aConnection,VoiceUserValueObject aVoiceUserValueObject) throws SQLException  { 
      String sql = " INSERT INTO VOICE_USER A ( A.ID, A.NAME, A.PASSWORD, A.TYPE, A.EMAIL ) VALUES ( ?, ?, ?, ?, ? )  " ;
      int result = 0;
      PreparedStatement prepStmt = aConnection.prepareStatement( sql.toString() );
      if (aVoiceUserValueObject.getId()  == null){ 
       prepStmt.setNull(1, Types.INTEGER);
      }else{ 
       prepStmt.setInt(1, aVoiceUserValueObject.getId().intValue() ); 
      }      
      if (aVoiceUserValueObject.getName()  == null){ 
       prepStmt.setNull(2, Types.VARCHAR);
      }else{ 
       prepStmt.setString(2, aVoiceUserValueObject.getName() ); 
      }
      if (aVoiceUserValueObject.getPassword()  == null){ 
       prepStmt.setNull(3, Types.VARCHAR);
      }else{ 
       prepStmt.setString(3, aVoiceUserValueObject.getPassword() ); 
      }
      if (aVoiceUserValueObject.getType()  == null){ 
       prepStmt.setNull(4, Types.INTEGER);
      }else{ 
       prepStmt.setInt(4, aVoiceUserValueObject.getType().intValue() ); 
      }      
      if (aVoiceUserValueObject.getEmail()  == null){ 
       prepStmt.setNull(5, Types.VARCHAR);
      }else{ 
       prepStmt.setString(5, aVoiceUserValueObject.getEmail() ); 
      }
      result = prepStmt.executeUpdate();
      prepStmt.close();
      return result ;
     } 

    public int update(Connection aConnection,VoiceUserValueObject aVoiceUserValueObject) throws SQLException  { 
      StringBuffer sql = new StringBuffer(" update VOICE_USER A  set " );
            if(aVoiceUserValueObject.getName()!=null&&!aVoiceUserValueObject.getName().equals("")){
            if(aVoiceUserValueObject.getName().equals("@_@"))sql.append( " A.NAME= null,");
            else sql.append(" A.NAME='"+aVoiceUserValueObject.getName()+"',");
      }
      if(aVoiceUserValueObject.getPassword()!=null&&!aVoiceUserValueObject.getPassword().equals("")){
            if(aVoiceUserValueObject.getPassword().equals("@_@"))sql.append( " A.PASSWORD= null,");
            else sql.append(" A.PASSWORD='"+aVoiceUserValueObject.getPassword()+"',");
      }
      if(aVoiceUserValueObject.getType()!=null){
            if(aVoiceUserValueObject.getType().doubleValue() == -1.0)sql.append(" A.TYPE= null,");
            else sql.append("  A.TYPE=").append(aVoiceUserValueObject.getType()).append(",");
      }
      if(aVoiceUserValueObject.getEmail()!=null&&!aVoiceUserValueObject.getEmail().equals("")){
            if(aVoiceUserValueObject.getEmail().equals("@_@"))sql.append( " A.EMAIL= null,");
            else sql.append(" A.EMAIL='"+aVoiceUserValueObject.getEmail()+"',");
      }

      //remove the last comma
      sql.setLength(sql.length()-1);
      sql .append( " where 1=1");
      if(aVoiceUserValueObject.getId()!=null){
      sql.append(" and A.ID=").append(aVoiceUserValueObject.getId());
      }

      int result = 0;
      PreparedStatement prepStmt = aConnection.prepareStatement( sql.toString() );
      result = prepStmt.executeUpdate();
      prepStmt.close();
      return result ;
     } 

    public int updateByQueryValue(Connection aConnection,VoiceUserValueObject aVoiceUserValueObject,VoiceUserQueryValue aVoiceUserQueryValue) throws SQLException  { 
      StringBuffer sql = new StringBuffer(" update VOICE_USER A  set " );
            if(aVoiceUserValueObject.getName()!=null&&!aVoiceUserValueObject.getName().equals("")){
            if(aVoiceUserValueObject.getName().equals("@_@"))sql.append( " A.NAME= null,");
            else sql.append(" A.NAME='"+aVoiceUserValueObject.getName()+"',");
      }
      if(aVoiceUserValueObject.getPassword()!=null&&!aVoiceUserValueObject.getPassword().equals("")){
            if(aVoiceUserValueObject.getPassword().equals("@_@"))sql.append( " A.PASSWORD= null,");
            else sql.append(" A.PASSWORD='"+aVoiceUserValueObject.getPassword()+"',");
      }
      if(aVoiceUserValueObject.getType()!=null){
            if(aVoiceUserValueObject.getType().doubleValue() == -1.0)sql.append(" A.TYPE= null,");
            else sql.append("  A.TYPE=").append(aVoiceUserValueObject.getType()).append(",");
      }
      if(aVoiceUserValueObject.getEmail()!=null&&!aVoiceUserValueObject.getEmail().equals("")){
            if(aVoiceUserValueObject.getEmail().equals("@_@"))sql.append( " A.EMAIL= null,");
            else sql.append(" A.EMAIL='"+aVoiceUserValueObject.getEmail()+"',");
      }

      //remove the last comma
      sql.setLength(sql.length()-1);
      sql .append( " where 1=1");
      String condition = aVoiceUserQueryValue.toSql();
      sql.append(condition);
      int result = 0;
      PreparedStatement prepStmt = aConnection.prepareStatement( sql.toString() );
      result = prepStmt.executeUpdate();
      prepStmt.close();
      return result ;
     } 

    public int delete(Connection aConnection,VoiceUserValueObject aVoiceUserValueObject) throws SQLException  { 
      StringBuffer sql = new StringBuffer(" delete  from  VOICE_USER A where 1=1");

      if(aVoiceUserValueObject.getId()!=null){
      sql.append(" and A.ID=").append(aVoiceUserValueObject.getId());
      }

      if(aVoiceUserValueObject.getName()!=null&&!aVoiceUserValueObject.getName().equals("")){
      sql.append(" and A.NAME='"+aVoiceUserValueObject.getName()).append("'");
      }

      if(aVoiceUserValueObject.getPassword()!=null&&!aVoiceUserValueObject.getPassword().equals("")){
      sql.append(" and A.PASSWORD='"+aVoiceUserValueObject.getPassword()).append("'");
      }

      if(aVoiceUserValueObject.getType()!=null){
      sql.append(" and A.TYPE=").append(aVoiceUserValueObject.getType());
      }

      if(aVoiceUserValueObject.getEmail()!=null&&!aVoiceUserValueObject.getEmail().equals("")){
      sql.append(" and A.EMAIL='"+aVoiceUserValueObject.getEmail()).append("'");
      }

      int result = 0;
      PreparedStatement prepStmt = aConnection.prepareStatement( sql.toString() );
      result = prepStmt.executeUpdate();
      prepStmt.close();
      return result ;
     } 

    public int deleteByQueryValue(Connection aConnection,VoiceUserQueryValue aVoiceUserQueryValue) throws SQLException  { 
      StringBuffer sql =new StringBuffer( " delete  from  VOICE_USER A where 1=1  ");

      String condition = aVoiceUserQueryValue.toSql();
      sql.append(condition);
      int result = 0;
      PreparedStatement prepStmt = aConnection.prepareStatement( sql.toString() );
      result = prepStmt.executeUpdate();
      prepStmt.close();
      return result ;
     } 

    public ArrayList supplement(Connection aConnection,VoiceUserValueObject aVoiceUserValueObject,int start,int end) throws SQLException  { 
      //---- variable sql be provided througth analyze the ValueObject  
      StringBuffer sql = new StringBuffer("SELECT A.ID, A.NAME, A.PASSWORD, A.TYPE, A.EMAIL FROM VOICE_USER A WHERE 1 = 1 " );

      if(aVoiceUserValueObject.getId()!=null){
      sql.append(" and A.ID=").append(aVoiceUserValueObject.getId());
      }

      if(aVoiceUserValueObject.getName()!=null&&!aVoiceUserValueObject.getName().equals("")){
      sql.append(" and A.NAME='"+aVoiceUserValueObject.getName()).append("'");
      }

      if(aVoiceUserValueObject.getPassword()!=null&&!aVoiceUserValueObject.getPassword().equals("")){
      sql.append(" and A.PASSWORD='"+aVoiceUserValueObject.getPassword()).append("'");
      }

      if(aVoiceUserValueObject.getType()!=null){
      sql.append(" and A.TYPE=").append(aVoiceUserValueObject.getType());
      }

      if(aVoiceUserValueObject.getEmail()!=null&&!aVoiceUserValueObject.getEmail().equals("")){
      sql.append(" and A.EMAIL='"+aVoiceUserValueObject.getEmail()).append("'");
      }

      //-----Result between variable start and variable end
      if (start != -1 && end != -1){
      String mainSql = sql.toString();
      sql = new StringBuffer("select * from ( select a.*,rownum as tmprow from (").append(mainSql).append(") a where rownum <=").append(end).append(") where tmprow>= ").append(start);
      }

      ResultSet rs = null;
      ArrayList list = new ArrayList();
      PreparedStatement prepStmt = aConnection.prepareStatement( sql.toString() );
      rs = prepStmt.executeQuery();
      while( rs.next() ) { 
        VoiceUserValueObject model = new VoiceUserValueObject();