?? packageconstants.java
字號:
package com.sunyard.dataanalyze;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.log4j.Logger;
public class PackageConstants {
public static final int PACKAGE_RQ = 1;//請求包
public static final int PACKAGE_RS = 2;//應答包
public static final int HEAD_SHORT = 14;//短包頭長度
public static final int HEAD_LONG = 22;//長包頭長度
public static final int TRADENO_START_SHORT = 8;//短包頭交易碼起始位置
public static final int TRADENO_START_LONG = 16;//長包頭交易碼起始位置
public static final int TRADENO_LENGTH = 6;//交易碼長度
public static final int LISTEN_PORT = 60006;//監聽端口
public static final int COMMIT_NUM = 100;//批量提交記錄條數
public static final long LIMIT_COMMIT_TIME = 60*1000;//提交記錄的最大時間間隔
public static final String PACKAGE_SPLIT_STR = "!";//交易包分割字符
public static final String SEND_PACKAKGE_ROOT = "TradeData";//發送XML文件根節點
public static final String FLOW_DB = "FLOWDB";
public static final String CFG_DB = "CFGDB";
//public static String TARGET_ADDR = "192.168.52.10";
//public static int TARGET_PORT = 4567;
private static Map FIELD_TYPE_MAPPIG_MAP = new HashMap();//字段類型映射
//private static Map FIELD_MAPPING_MAP = new HashMap();//字段映射表
private static List SQL_LIST = new SQLList();//SQL語句
private static Map NOT_NULLABLE_FIELD_MAP = new HashMap();//不能為空的字段
public static Logger log = Logger.getLogger("realflow");
public static Map getFieldTypeMap(){
if(FIELD_TYPE_MAPPIG_MAP.size()==0){
resetTypeMap();
System.out.println("初始化FIELDTYPEMAP");
}
return FIELD_TYPE_MAPPIG_MAP;
}
/*public static Map getFieldMapping(){
if(FIELD_MAPPING_MAP.size()==0){
resetFieldMapping();
System.out.println("初始化FIELD_MAPPING_MAP");
}
return FIELD_MAPPING_MAP;
}*/
public static void resetTypeMap(){
ConnectionFactory cf = new ConnectionFactoryImpl();
Connection conn = cf.getConnection(FLOW_DB);
try{
DatabaseMetaData dm = conn.getMetaData();
ResultSet rs = dm.getColumns(null, "%", "fl_flow_tb", "%");
while(rs.next()){
String columnName = (rs.getString("COLUMN_NAME")).toUpperCase();
String columnType = rs.getString("TYPE_NAME");
int nullable = rs.getInt("NULLABLE");
FIELD_TYPE_MAPPIG_MAP.put(columnName, columnType);
if(nullable == 0){
NOT_NULLABLE_FIELD_MAP.put(columnName, columnType);
}
}
NOT_NULLABLE_FIELD_MAP.remove("SEQ_ID");
rs.close();
conn.close();
}catch(SQLException e){
e.printStackTrace();
}
}
public static Map getNotNullableFieldMap(){
return NOT_NULLABLE_FIELD_MAP;
}
public static List getSQLs(){
return SQL_LIST;
}
public static void resetSQLs(){
SQL_LIST.clear();
}
/*public static void resetFieldMapping(){
ConnectionFactory cf = new ConnectionFactoryImpl();
Connection conn = cf.getConnection(CFG_DB);
Statement stmt = null;
ResultSet rs = null;
try{
stmt = conn.createStatement();
rs = stmt.executeQuery("SELECT * FROM SM_FIELDMAPPING_TB");
while(rs.next()){
String packageField = (rs.getString("PACKAGE_FIELD")).toUpperCase();
String flowField = (rs.getString("FLOWTB_FIELD")).toUpperCase();
FIELD_MAPPING_MAP.put(packageField, flowField);
}
rs.close();
stmt.close();
}catch (SQLException e){
e.printStackTrace();
}
}*/
public static void main(String args[]){
resetTypeMap();
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -