dbbean.java

this is jave package for system parament

package com.talent.publics;

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

import java.io.*;
import java.sql.*;
import java.util.*;
import javax.sql.*;
import javax.naming.*;
import javax.transaction.UserTransaction;
import weblogic.jndi.*;

public class DbBean {

  private  String subJndi="";
  private  String subUser="";
  private  String subPassword="";
  private  Connection dbCon;
  private  static final String INITIALCONTEXTFACTORY = "weblogic.jndi.WLInitialContextFactory";
  private  static final String PROVIDERURL = "t3://localhost:7001";

  public DbBean() throws SQLException, IOException{
    try {
      connect();
    }
    catch (Exception ex) {
    }
  }

  private  void  getParameter() throws IOException{
    String jndi;
    String user;
    String password;
    int    length;

    File file = new File("./applications/DefaultWebApp/connect.cfg");

    FileInputStream inFile   = new FileInputStream(file);
    DataInputStream inStream = new DataInputStream(inFile);

    jndi	= inStream.readLine();
    user	= inStream.readLine();
    password 	= inStream.readLine();

  //check jndi
   if(jndi.trim().substring(0,4).equals("JNDI")){
     length 	  = jndi.trim().indexOf("//");
     this.subJndi = jndi.trim().substring(6,length).trim();
     System.out.println("JDNI="+this.subJndi);
   }else{
     if(jndi.trim().substring(0,4).equals("USER")){
       length 	= jndi.trim().indexOf("//");
       this.subUser 	= jndi.trim().substring(6,length).trim();
       System.out.println("USER="+this.subUser);
     }else{
       if(jndi.trim().substring(0,8).equals("PASSWORD")){
         length 		= jndi.trim().indexOf("//");
         this.subPassword 	= jndi.trim().substring(10,length).trim();
         System.out.println("PASSDORD="+this.subPassword);
       }
     }
   }
  //check user
   if(user.trim().substring(0,4).equals("JNDI")){
     length	= user.trim().indexOf("//");
     this.subJndi	= user.trim().substring(6,length).trim();
     System.out.println("JDNI="+this.subJndi);
   }else{
     if(user.trim().substring(0,4).equals("USER")){
       length 	= user.trim().indexOf("//");
       this.subUser 	= user.trim().substring(6,length).trim();
       System.out.println("USER="+this.subUser);
     }else{
       if(user.trim().substring(0,8).equals("PASSWORD")){
         length = user.trim().indexOf("//");
         this.subPassword = user.trim().substring(10,length).trim();
         System.out.println("PASSDORD="+this.subPassword);
       }
     }
   }
  //check password
   if(password.trim().substring(0,4).equals("JNDI")){
     length = password.trim().indexOf("//");
     this.subJndi = password.trim().substring(6,length).trim();
     System.out.println("JDNI="+this.subJndi);
   }else{
     if(password.trim().substring(0,4).equals("USER")){
       length = password.trim().indexOf("//");
       this.subUser = password.trim().substring(6,length).trim();
       System.out.println("USER="+this.subUser);
     }else{
       if(password.trim().substring(0,8).equals("PASSWORD")){
         length = password.trim().indexOf("//");
         this.subPassword = password.trim().substring(10,length).trim();
         System.out.println("PASSDORD="+this.subPassword);
       }
     }
   }
   inStream.close();
   inFile.close();
 }

   private  boolean connect() throws ClassNotFoundException, SQLException, IOException {
     Hashtable env=new Hashtable();
     Context context=null;
     try{
       getParameter();
     }catch(Exception e){
     }
     env.put(Context.INITIAL_CONTEXT_FACTORY,INITIALCONTEXTFACTORY);
     env.put(Context.PROVIDER_URL,PROVIDERURL);
     env.put(Context.SECURITY_PRINCIPAL,this.subUser);
     env.put(Context.SECURITY_CREDENTIALS,this.subPassword);
     try{
       context=new InitialContext(env);
       javax.sql.DataSource ds=(DataSource)context.lookup(this.subJndi);
       dbCon=ds.getConnection();
       dbCon.setAutoCommit(false);
       return true;
     }
     catch(Exception ex){
       ex.printStackTrace();
       return false;
     }
   }

   public Connection getConnection(){
     return this.dbCon;
   }

   public ResultSet execQuery(String sql) throws SQLException, IOException {
    try{
       if(this.dbCon==null){
          this.connect();
        }
        Statement s = dbCon.createStatement();
        ResultSet r = s.executeQuery(sql);
        return (r == null) ? null : r;
      }catch(ClassNotFoundException ex){
        ex.printStackTrace();
        return null;
      }
  }

  public boolean execUpdate(String sql) throws SQLException {
    Statement s = dbCon.createStatement();
    s.execute(sql);
    return true;
  }

  public void commit() throws SQLException{
    dbCon.commit();
  }
  public void close() throws SQLException {
      dbCon.commit();
      dbCon.close();
  }
}