submitdb.java~1~

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 SubmitDb {
  private  Connection conn ;
  private  Statement stmt ;

  public SubmitDb() {
  }
//insert()  id<=0x7fffffff
/*
数据库字段名  int id, int seq , String  media_type, String  service_type , String  source_address ,
            String   destination_address, byte  esm_class, byte  priority_flag, String  schedule_delivery_time,
            String   validity_peroid, byte   registered_delivery_flag, byte   replace_if_present_flag, byte  data_coding, String  short_message_text,
            String   fee_Type, String   fee_userType,  String   fee_terminal, String   flag
*/

public Vector queryResults(int count)
 {
       Vector Result = new Vector();
       Vector Row = new Vector();
       ResultSet rs = null;
       String SELECT_Sql="select * from cnc_submit where flag = '0' and rownum <="+count+"order by id";
       try
       {
           conn = cncMain.poolmanager.getConnection("cnc");
           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));
                Row.addElement(rs.getString(11));
                Row.addElement(rs.getString(12));
                Row.addElement(rs.getString(13));
                Row.addElement(rs.getString(14));
                Row.addElement(rs.getString(15));
                Row.addElement(rs.getString(16));
                Row.addElement(rs.getString(17));
                Row.addElement(rs.getString(18));


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

    public boolean updateHaveSent(int seq){

                  boolean flag = false;

                  String sql = "update cnc_submit set flag = 1 where seq = ?";
                  conn = cncMain.poolmanager.getConnection("cnc");
                  PreparedStatement prepare = null;

                  try {
                    System.out.println("prepare...............");
                      prepare  = conn.prepareStatement(sql);
                  }
                  catch (SQLException ex) {
                  }

                  try{
                      prepare.setInt(1,seq);
                      conn.setAutoCommit(false);
                      prepare.execute();

                      conn.commit();
                      flag = true;
                  }catch(Exception e){
                      try{
                          conn.rollback();
                          }catch(Exception es){}
                          cncMain.errorlog("数据库错误："+e.getMessage());
                          flag = false;
                  }finally{
                      try{
                          prepare.close();
                          cncMain.poolmanager.freeConnection("cnc",conn);
                          }catch(Exception e){
                            cncMain.errorlog("关闭连接错误");
                          }
                  }
                  return flag;
           }


}