deliverdb.java~2~

cnc网通小灵通网关接口源码

package cncgw.smdb;

/**
 * <p>Title: cncGateWay</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: gramsoft</p>
 * @author lee
 * @version 1.0
 */
import java.sql.*;
import java.sql.Date;
import java.util.*;
import cncgw.cncMain;

public class DeliverDb {

  private  Connection conn ;
  private  Statement stmt ;

  public DeliverDb() {
  }

/*
数据库字段名  int id, int seq , String  media_type, String  service_type , String  source_address ,
            String   destination_address, String  esm_class, String  priority_flag ,String  short_msg, String  flag,

*/




    public  synchronized boolean insertDBByID(int seq,String media_type,String service_type,String src_addr,String dest_addr,byte esm_class,byte priority_flag,String short_msg,String flag)
    {
        boolean ret=false;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        String INSERT_SONG ="";
        try {
              conn = cncMain.poolmanager.getConnection("cnc");
            conn.setAutoCommit(false);
            String INSERT_Phone =
                    "Insert Into cnc_deliver(id,seq,media_type,service_type,src_addr,dest_addr,esm_class,priority_flag,short_msg,flag)  "
                    + "Values(cnc_deliver_id.nextval,?,?,?,?,?,?,?,?,?)";
            pstmt = conn.prepareStatement(INSERT_Phone);

            pstmt.setInt(1,seq);
            pstmt.setString(2,media_type);
            pstmt.setString(3,service_type);
            pstmt.setString(4,src_addr);
            pstmt.setString(5,dest_addr);
            pstmt.setByte(6,esm_class);
            pstmt.setByte(7,priority_flag);
            pstmt.setString(8,short_msg);
            pstmt.setString(9,flag);
            pstmt.executeUpdate() ;

            ret=true;
        }
        catch(SQLException ex) {
            cncMain.errorlog("打开数据库或执行insertSQL时出错:"+ex.getMessage());
            ret=false;
            return ret;
        }
        finally{
            try{
                if(ret)
                    conn.commit();
                else
                    conn.rollback();
                pstmt.close();
                cncMain.poolmanager.freeConnection("cnc",conn);
            }catch(Exception ie){
               cncMain.errorlog("关闭数据库出错:"+ie.getMessage());
            }
        }
        return ret;
    }

  public Vector queryResults(String count)
  {
        Vector Result = new Vector();
        Vector Row = new Vector();
        ResultSet rs = null;
        String SELECT_Sql="select * from cnc_deliver where 1=1 and rownum <="+count+"order by id";
        try
        {
            conn = cncMain.poolmanager.getConnection("cnc");
            conn.setAutoCommit(false);
            stmt=conn.createStatement();
            rs=stmt.executeQuery(SELECT_Sql);
            for(;rs.next();)
            {
                 Row.addElement(rs.getString(1));
                 Row.addElement(rs.getString(2));
                 Row.addElement(rs.getString(3));
                 Row.addElement(rs.getString(4));
                 Row.addElement(rs.getString(5));
                 Row.addElement(rs.getString(6));
                 Row.addElement(rs.getString(7));
                 Row.addElement(rs.getString(8));
                 Row.addElement(rs.getString(9));
                 Row.addElement(rs.getString(10));


                 Result.addElement(Row.clone());
                 Row.clear();
             }
         }
         catch(SQLException ex) {
             cncMain.errorlog("打开数据库或执行insertSQL时出错:"+ex.getMessage());
         }
         finally{
             try{
                 cncMain.poolmanager.freeConnection("cnc",conn);
             }catch(Exception ie){
                 cncMain.errorlog("关闭数据库出错:"+ie.getMessage());
             }
         }
         return Result;
     }

}