beannszx.java

一个建立Oracle序号发生器并调用的小例子程序,其中包含Oracle中序号发生器的建立

package frame.bean;

import frame.db.*;
import frame.config.*;
import java.util.*;
import java.sql.*;
import java.io.*;

/**
 * <p>Title: 纳税咨询</p>
 * <p>Description: 纳税咨询</p>
 * <p>Copyright: Copyright (c) 2002</p>
 * <p>Company: DigitalChina</p>
 * @author 王向前
 * @version 1.0
 */

public class BeanNszx {

    public Vector queryData(String lmbh, int systemFlag) {
        Connection conn = null;
        Vector gsltVector = new Vector();
        try {
            //建立数据库连接
            if (systemFlag == Const.IS_INTRANET) {
                conn = DBConnection.getConnection(Const.IS_INTRANET, Const.IS_AUTOCOMMIT);
            } else if (systemFlag == Const.IS_INTERNET) {
                conn = DBConnection.getConnection(Const.IS_INTERNET, Const.IS_AUTOCOMMIT);
            } else {
                return gsltVector;
            }
  //          System.out.println(lmbh);
            //建立 statement
            Statement stmt = conn.createStatement();
            //stmt.execute("set rowcount 5");

            //取数据
            ResultSet result = stmt.executeQuery("select SJBH, BT,URL,LRRQ,LMBH,ZXNSR from NSZX where LMBH='"+
                lmbh+"' and ZTBZ='01' order by LRRQ desc, LRSJ desc");
            //System.out.println(result.toString());
           while (result.next()) {

                Hashtable row = new Hashtable();
                // 杨波加入汉字转换 2002/08/20

                row.put("SJBH",  result.getString(1) );
                row.put("BT",  EncodingConfig.changeDatabaseToServerEncoding(result.getString(2)));
//                row.put("URL", EncodingConfig.changeDatabaseToServerEncoding(result.getString(3)));
                row.put("LRRQ", EncodingConfig.changeDatabaseToServerEncoding(result.getString(4)));
                row.put("LMBH", EncodingConfig.changeDatabaseToServerEncoding(result.getString(5)));
                row.put("ZXNSR", EncodingConfig.changeDatabaseToServerEncoding(result.getString(6)));
                gsltVector.add(row);
            }
//System.out.println(lmbh+gsltVector);
            //关闭 statement
            //stmt.execute("set rowcount 0");
            stmt.close();

        }catch(DBException e){
            System.out.println(e.toString());
        }catch(Exception e){
            System.out.println(e.toString());
        }finally{//关闭数据库连接
            try {
                if (conn != null) conn.close();
            }catch(Exception e){
            }
        }

        return gsltVector;
    }
/*
===============================================================================
===============================================================================
函数说明：
    public Vector queryDataBySjbh(String StrSjbh,int systemFlag)
功能描述：
    查询显示，取消原来通过邮件的方式，能够通过页面显示数据
创建人：
    王向前
创建时间
    2003-09-17
===============================================================================
===============================================================================
*/
    public Vector queryDataBySjbh(String StrSjbh,int systemFlag) {
        Connection conn = null;
        Vector gsltVector = new Vector();
        try {
            //建立数据库连接
            if (systemFlag == Const.IS_INTRANET) {
                conn = DBConnection.getConnection(Const.IS_INTRANET, Const.IS_AUTOCOMMIT);
            } else if (systemFlag == Const.IS_INTERNET) {
                conn = DBConnection.getConnection(Const.IS_INTERNET, Const.IS_AUTOCOMMIT);
            } else {
                return gsltVector;
            }
            frame.logic.BeanNszx beanNszx = new frame.logic.BeanNszx(StrSjbh);
            beanNszx.select(conn);
            Hashtable hash = new Hashtable();
            hash.put("SJBH",beanNszx.getSjbh());
            hash.put("BT",beanNszx.getBt());
//            hash.put("URL",beanNszx.getUrl());
            hash.put("LRRQ",beanNszx.getLrrq());
            hash.put("LMBH",beanNszx.getLmbh());
            hash.put("ZXNSR",beanNszx.getZxnsr());
            hash.put("ZXZW",beanNszx.getZxzw());
            String strhfzw=beanNszx.getHfzw();
            if(strhfzw!=null && !strhfzw.equals("")){
                hash.put("PFYJ",strhfzw);
            }
            Statement stmt = conn.createStatement();
            ResultSet result = stmt.executeQuery("select LMMC from LMLB where LMBH='"+beanNszx.getLmbh()+"'");
            if(result.next()){
                hash.put("LMMC", EncodingConfig.changeDatabaseToServerEncoding(result.getString(1)));
            }
            stmt.close();
            gsltVector.add(hash);

        }catch(DBException e){
            e.printStackTrace();
        }catch(Exception e){
            e.printStackTrace();
        }finally{//关闭数据库连接
            try {
                if (conn != null) conn.close();
            }catch(Exception e){
            }
        }

        return gsltVector;
    }
}