tablevalue.java

农业银行ATM对帐查询系统后台类包的源代码,实现了FTP,数据库管理等等功能

package boco.shabank.dbmanager;

/**
 * <p>Title: boco dbmanager</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2002</p>
 * <p>Company: boco</p>
 * @author wjb
 * @version 1.0
 */
import java.util.*;
import java.awt.*;
import javax.swing.*;
import javax.swing.tree.*;
import javax.swing.table.*;
import javax.swing.border.*;
import java.sql.*;
import javax.swing.table.AbstractTableModel;
import javax.swing.event.TableModelEvent;
import boco.shabank.dbconnection.*;

//****************************************************************************
//类名称：表格值模板
//类功能：完成数据表格的值的显示
//****************************************************************************
public class TableValue extends AbstractTableModel {
    int KeyAt;
    String KeyType;
    int columnSize;
    Object temp=null;
    Vector columnNames=new Vector();
    Vector columnType=new Vector();
    public Vector values=new Vector();
    DBConnectionManager objDBConnection;
//******************************************************************************
//方法名称：构造函数
//方法功能：连接池
//******************************************************************************
  public TableValue() {
  }
  public TableValue(DefaultMutableTreeNode node,String Key) {
        //define
        int j;
        int ColNums;
        Vector tmpNull = new Vector();
        ChineseTransfer A2C = new ChineseTransfer();

        //System.out.println("Static URLName="+DBSName);
        //connect to dburl
        //String URLName = pathnode.getPathComponent(1).toString();
        //System.out.println("URLName="+URLName);
        String DBSName = "access";
        String TableName = "dbtable";
        String dbsName = node.toString();
        //System.out.println("TableName="+TableName);
        //String sql = "select * from dbtable where db";
        String sql = "select DBTId,DBTName,DBTType,DBTRemark,DBTKey from dbtable where dbsid in (select dbsid from dbsource where dbsname ='"+dbsName+"') order by dbtid";
        //:test:System.out.println("sql===="+sql);
        Connection m_Connection;
        DBAccess db;
        db =new DBAccess();
        objDBConnection=objDBConnection.getInstance() ;
        try{
            m_Connection = objDBConnection.getConnection("access") ;
            ResultSet rs=db.executeQuery(m_Connection,sql);
            ResultSetMetaData rsmd=rs.getMetaData();
            ColNums = rsmd.getColumnCount();
            //System.out.println("tvKey:"+Key);
            for(int i=1;i<=ColNums;i++){
                if((Key.trim()).equalsIgnoreCase(rsmd.getColumnName(i))){
                  KeyAt = i-1;
                  //System.out.println("tvKeyAt:"+KeyAt);
                  KeyType = rsmd.getColumnTypeName(i);
                  //System.out.println("tvKeyType:"+KeyType);
                }
                columnType.addElement(rsmd.getColumnTypeName(i));
                columnNames.addElement(rsmd.getColumnName(i));
                //System.out.println("columnname="+columnNames.elementAt(i-1));
            }
            //get values
            while(rs.next()){
                  Vector Vtemp = new Vector();
                  for(j=0;j<ColNums;j++){
                      //:test:System.out.println("Column=" + (j+1));
                      //:test:System.out.println("StringValue=" + rs.getString(j+1));
                      //Do with null string and chinese string
                      //if(URLName.equals("sybaccess")){
                      //  Vtemp.addElement(rs.getString(j+1));
                      //}
                      //else{
                      if(rs.getString(j+1)==null)
                          Vtemp.addElement(rs.getString(j+1));
                      else
                          Vtemp.addElement(A2C.AsciiToChineseString(rs.getString(j+1)));
                  //}
                  }
                  values.addElement(Vtemp);
             }
            //新增一空行
            for(int i=1;i<=ColNums;i++){
              tmpNull.addElement("");
            }
            values.addElement(tmpNull);
            //free connection
            rs.close();
            objDBConnection.freeConnection("access",m_Connection) ;
        }
        catch(Exception ex){
            System.out.println("message="+ex.getMessage()) ;
        }
  }
  //构造函数，表字段属性表
  public TableValue(DefaultMutableTreeNode node,String Key,String dbsName,String TabelType) {
        //define
        int j;
        int ColNums;
        Vector tmpNull = new Vector();
        ChineseTransfer A2C = new ChineseTransfer();
        String DBSName = "access";
        String TableName = "dbfiled";
        String dbtName = node.toString();
        String sql = "select dbfid,dbfname,dbfnamecn,dbfoperator,dbtremark,dbftype from dbfield where dbtid in (select dbtid from dbtable where dbtname='"+dbtName+"' and dbsid in (select dbsid from dbsource where dbsname='"+ dbsName +"')) order by dbfid";
        //System.out.println("sql==+"+sql);
        Connection m_Connection;
        DBAccess db;
        db =new DBAccess();
        objDBConnection=objDBConnection.getInstance() ;
        try{
            m_Connection = objDBConnection.getConnection("access") ;
            ResultSet rs=db.executeQuery(m_Connection,sql);
            ResultSetMetaData rsmd=rs.getMetaData();
            ColNums = rsmd.getColumnCount();
            //System.out.println("tvKey:"+Key);
            for(int i=1;i<=ColNums;i++){
                if((Key.trim()).equalsIgnoreCase(rsmd.getColumnName(i))){
                  KeyAt = i-1;
                  //System.out.println("tvKeyAt:"+KeyAt);
                  KeyType = rsmd.getColumnTypeName(i);
                  //System.out.println("tvKeyType:"+KeyType);
                }
                columnNames.addElement(rsmd.getColumnName(i));
                columnType.addElement(rsmd.getColumnTypeName(i));
                //System.out.println("columnName ="+columnNames.elementAt(i-1));
            }
            //get values
            while(rs.next()){
                  Vector Vtemp = new Vector();
                  for(j=0;j<ColNums;j++){
                      //:test:System.out.println("Column=" + (j+1));
                      //:test:System.out.println("StringValue=" + rs.getString(j+1));
                      //Do with null string and chinese string
                      //if(URLName.equals("sybaccess")){
                      //  Vtemp.addElement(rs.getString(j+1));
                      //}
                      //else{
                      if(rs.getString(j+1)==null)
                          Vtemp.addElement(rs.getString(j+1));
                      else
                          Vtemp.addElement(A2C.AsciiToChineseString(rs.getString(j+1)));
                  //}
                  }
                  values.addElement(Vtemp);
             }
            //新增一空行
            for(int i=1;i<=ColNums;i++){
              tmpNull.addElement("");
            }
            values.addElement(tmpNull);
            //free connection
            rs.close();
            objDBConnection.freeConnection("access",m_Connection) ;
        }
        catch(Exception ex){
            System.out.println("message="+ex.getMessage()) ;
        }
  }
  //构造函数，不同类型表属性
  public TableValue(DefaultMutableTreeNode node,String Key,String dbsName) {
        //define
        int j;
        int ColNums;
        Vector tmpNull = new Vector();
        ChineseTransfer A2C = new ChineseTransfer();
        String DBSName = "access";
        String TableName = "dbtable";
        String dbttype = A2C.ChineseStringToAscii(node.toString());
        String sql = "select DBTId,DBTName,DBTType,DBTRemark,DBTKey from dbtable where DBTType = '"+dbttype+"' and dbsid in (select dbsid from dbsource where dbsname ='"+dbsName+"') order by dbtid";
        //System.out.println("sql=="+sql);
        Connection m_Connection;
        DBAccess db;
        db =new DBAccess();
        objDBConnection=objDBConnection.getInstance() ;
        try{
            m_Connection = objDBConnection.getConnection("access") ;
            ResultSet rs=db.executeQuery(m_Connection,sql);
            ResultSetMetaData rsmd=rs.getMetaData();
            ColNums = rsmd.getColumnCount();
            //System.out.println("tvKey:"+Key);
            for(int i=1;i<=ColNums;i++){
                if((Key.trim()).equalsIgnoreCase(rsmd.getColumnName(i))){
                  KeyAt = i-1;
                  //System.out.println("tvKeyAt:"+KeyAt);
                  KeyType = rsmd.getColumnTypeName(i);
                  //System.out.println("tvKeyType:"+KeyType);
                }
                columnNames.addElement(rsmd.getColumnName(i));
                columnType.addElement(rsmd.getColumnTypeName(i));
                //System.out.println("columname="+columnNames.elementAt(i-1));