parameterbean.java

this is java package for system parament

package com.talent.system.parameter;

/**
* Title:        ParameterBean.java
* Description:  Complete DataBase Connection
* Copyright:    Copyright (c) 2001 2002-12-08
* Company:      www.chinatalent.com
* @author:      jingyucui
* @version:     V1.0
* @changes:
*/

import java.io.*;
import java.lang.*;
import java.rmi.*;
import java.lang.Integer;
import java.sql.ResultSet;
import java.io.PrintStream;
import java.sql.SQLException;
import java.sql.ResultSetMetaData;
import javax.ejb.*;
import javax.sql.RowSet;
import javax.naming.Context;
import javax.servlet.ServletException;
import sun.jdbc.rowset.CachedRowSet;
import com.talent.publics.DbBean;
import com.talent.publics.GetSqlBean;

public class ParameterBean implements SessionBean {
  private SessionContext sessionContext;
  GetSqlBean  getSqlBean = new GetSqlBean();
  String sql = "";
  public void ejbCreate() {
  }
  public void ejbRemove() throws RemoteException {
  }
  public void ejbActivate() throws RemoteException {
  }
  public void ejbPassivate() throws RemoteException {
  }
  public void setSessionContext(SessionContext sessionContext) throws RemoteException {
    this.sessionContext = sessionContext;
  }

  //*********System表查询**********//
  public RowSet parameterSelect(String sql) throws RemoteException,SQLException{
    if(sql.equals("")){
      sql = "SELECT * FROM SYSTEM ORDER BY SYSTEMID";
    }else if(sql.equals("INSERT")){
      sql = "SELECT * FROM SYSTEM,(SELECT MAX(INDATE) MAXINDATE FROM SYSTEM)TEMPA  WHERE SYSTEM.INDATE=TEMPA.MAXINDATE ORDER BY SYSTEMID";
    }else {
      sql = "SELECT * FROM SYSTEM WHERE " + sql;
    }
    System.err.println("SystemFindSql="+sql);
    try {
         DbBean db=new DbBean();
         ResultSet resultSet=db.execQuery(sql);
         CachedRowSet crs=new CachedRowSet();
         crs.populate(resultSet);
         db.close();
         return crs;
    }
    catch (Exception ex) {
      db.close();
      return null;
    }
  }
  //*********System表记录插入**********//
  public boolean parameterInsert(String insertSql,String parameterId) throws RemoteException,SQLException{
    int maxId      = 0;
    int count      = 0;
    int i          = 0;
    int j          = 0;
    int maxLength  = 0;
    int length     = parameterId.length()+4;
    int leftLength = parameterId.length()-4;
    String id      = "";
    String id1     = "";
    String id2     = "";
    String flag    = "";
    String departClass = "'" + String.valueOf(parameterId.length()/4+1) + "'";
    sql = "SELECT COUNT(*) FROM SYSTEM WHERE SUBSTR(SYSTEMID,0," + parameterId.length()+") = '" + parameterId + "'  AND LENGTH(SYSTEMID) = " + length;
System.out.println("delectcountsql ==========="+sql);
    try {
         DbBean    db = new DbBean();
         ResultSet rs = db.execQuery(sql);
         while(rs.next()){
           count = rs.getInt(1);
         }
         if (count > 0){
//存在的情况
System.out.println("存在情况！！！！！！");
           sql = "SELECT MAX(LENGTH(SYSTEMID)) FROM SYSTEM WHERE SUBSTR(SYSTEMID,0,"+parameterId.length()+") = " + parameterId;
           rs = db.execQuery(sql);
System.err.println("selectmaxlength======="+sql);
            while(rs.next()){
              maxId = rs.getInt(1);
            }
System.out.print("maxid=========="+maxId);
            if (maxId > length){
              flag = "'0'";
            }else{
              flag = "'1'";
            }
           sql = "SELECT MAX(SYSTEMID) FROM SYSTEM WHERE LENGTH(SYSTEMID) = " + length + " AND SUBSTR(SYSTEMID,0,"+parameterId.length()+") = " + parameterId;
System.err.println("selectmaxId========="+sql);
           rs = db.execQuery(sql);
           while(rs.next()){
              id    = rs.getString(1);
              id    = String.valueOf(Integer.valueOf(id).intValue()+1);
              j = parameterId.length()+4;
              i = id.length();
           }
           for(;i<j;i++){
             id ="0" + id;
           }
           id = "'"+id+"'";
System.err.println("id======="+id);
//不存在的情况
         }else{
System.out.println("不存在情况！！！！！！");
           if (parameterId.equals("")){
             sql = "SELECT MAX(SYSTEMID) FROM SYSTEM WHERE LENGTH(SYSTEMID) = 4";
             rs = db.execQuery(sql);
             while(rs.next()){
               id = rs.getString(1);
             }
             if (id==null){
               id = "0001";
             }else{
               id = String.valueOf(Integer.valueOf(id).intValue()+1);
               j = 4-id.length();
             }
             for(i=0;i<j;i++){
               id ="0" + id;
             }
             id = "'"+id+"'";
             flag = "'1'";
           }else{
             id = "'"+parameterId+"0001'";
             flag = "'1'";
             if (parameterId.length()==4){
               sql = "UPDATE SYSTEM SET FLAG = '0' WHERE SYSTEMID = " + parameterId;
             }else{
               sql = "UPDATE SYSTEM SET FLAG = '0' WHERE SUBSTR(SYSTEMID,0," + leftLength+") = '" + parameterId.substring(0,leftLength) + "' AND LENGTH(SYSTEMID) = " + parameterId.length();
             }
             System.err.println("UPDATEFLAGSQL========="+sql);
             if (!db.execUpdate(sql)){
               System.out.println("修改原有的最后级别标志错！");
               db.close();
               return false;
             }
           }
         }
         departClass = "'"+String.valueOf(parameterId.length()/4+1)+"'";
System.out.println("FLAG========"+flag);
System.out.println("Class========"+departClass);
         sql = getSqlBean.getInsertSql(insertSql,"SYSTEM","SYSTEMID,FLAG,CLASS",id+","+flag+","+departClass.trim());
         System.err.println("ParameterInsertsql="+sql);
         if (!db.execUpdate(sql)){
           db.close();
           return false;
         }
         db.close();
         return true;
    }
    catch (Exception ex) {
      System.err.println("插入数据错！");
      db.close();
      return false;
    }
  }
  //*********System记录删除**********//
  public boolean parameterDelete(String parameterId) throws RemoteException,SQLException{
    String sql;
    sql = "DELETE FROM SYSTEM WHERE SYSTEMID =  " + parameterId;
    System.err.println("FindSql="+sql);
    try {
         DbBean db=new DbBean();
         db.execUpdate(sql);
         db.close();
         return true;
    }
    catch (Exception ex) {
      System.err.println("删除数据错！");
      db.close();
      return false;
    }
  }

  //*********System记录修改**********//
  public boolean parameterUpdate(String updateSql) throws RemoteException,SQLException{
    try {
         DbBean db=new DbBean();
         sql = getSqlBean.getCheckUpdateSql(updateSql,"SYSTEM","SYSTEMID");
    System.err.println("ParametCheckUpdateSql="+sql);
         db.execUpdate(sql);
         db.commit();
         sql = getSqlBean.getUpdateSql(updateSql,"SYSTEM","SYSTEMID");
    System.err.println("ParameterUpdateSql="+sql);
         db.execUpdate(sql);
         db.close();
         return true;
    }
    catch (Exception ex) {
      System.err.println("修改数据错！");
      db.close();
      return false;
    }
  }
    private DbBean db;
}