connectinfo.java

好像是一个SQL执行器的设计实现

package mytools.sqlclient;

import mytools.sqlbean.*;

/**
 * <p>Title:连接信息类 </p>
 * <p>Description: 连接信息类</p>
 * <p>Copyright: Copyright (c) 2001</p>
 * <p>Company: jhtop</p>
 * @author lhg
 * @version 1.0
 */
public class ConnectInfo
{
    private String threadName="";       //线程名
    private IConnection connection=null; //数据库连接对象
    private boolean used=false;         //使用标志
    private boolean inTransaction=false; //在事务中标志
    private long beginTime;              //开始时间
    public ConnectInfo()
    {
       reset();
    }

    public ConnectInfo(String ps_threadName,IConnection po_connection)
    {
        threadName=ps_threadName;
        connection=po_connection;
        used=false;
        inTransaction=false;
        beginTime=System.currentTimeMillis();  //开始时间
    }

    public ConnectInfo(String ps_threadName,IConnection po_connection,boolean pb_used,boolean pb_inTransaction)
    {
        threadName=ps_threadName;
        connection=po_connection;
        used=pb_used;
        inTransaction=pb_inTransaction;
        beginTime=System.currentTimeMillis();
    }

    /**
     功能:初始化信息
     @param 无
     @return 无
    */
    public void reset()
    {
        threadName="";
        connection=null;
        used=false;
        inTransaction=false;
        beginTime=System.currentTimeMillis();  //开始时间
    }

    /**
    功能:取得开始时间
    @param 无
    @return 开始时间
    */
    public long getBeginTime()
    {
        return this.beginTime;
    }

    /**
    功能:设置开始时间
    @param pl_btime 开始时间
    @return 无
    */
    public void setBeginTime(long pl_btime)
    {
      this.beginTime=pl_btime;
    }
    /**
     功能: 取得线程名
     @param 无
     @return 线程名
    */
    public String getThreadName()
    {
        return threadName;
    }

    /**
     功能: 设置线程名
     @param ps_threadName 线程名
     @return 无
    */
    public void setThreadName(String ps_threadName)
    {
        threadName=ps_threadName;
    }

    /**
     功能: 取得数据库连接
     @param 无
     @return 数据库连接对象
    */
    public IConnection getConnection()
    {
        return connection;
    }

    /**
     功能: 设置数据库连接对象
     @param po_connection sql对象
     @return 无
    */
    public void setConnection(IConnection po_connection)
    {
        connection=po_connection;
    }

    /**
     功能: 判断本连接是否被占用
     @param 无
     @return true 是 false 否
    */
    public boolean isUsed()
    {
        return used;
    }
    /**
     功能: 设置本连接被占用标志
     @param pb_used 被占用标志
     @return 无
    */
    public void setUsed(boolean pb_used)
    {
        used=pb_used;
    }

   /**
     功能: 判断本连接是否在事务中
     @param 无
     @return true 是 false 否
    */
    public boolean isInTransaction()
    {
        return inTransaction;
    }
    /**
     功能: 设置本连接在事务中标志
     @param pb_inTranaction 在事务中标志
     @return 无
    */
    public void setInTransaction(boolean pb_inTransaction)
    {
        inTransaction=pb_inTransaction;
    }

    /**
     功能:设置本连接被ps_threadName线程占用
     @param ps_threadName 线程名
     @return 无
    */
    public void useBy(String ps_threadName)
    {
        threadName=ps_threadName;
        used=true;
        inTransaction=false;
    }

    /**
     功能: 设置本连接未使用
     @param 无
     @return 无
    */
    public void notUse()
    {
        threadName="";
        used=false;
        inTransaction=false;
        beginTime=System.currentTimeMillis();
    }

    /**
     功能: 将对象转为串信息
     @param 无
     @return 串信息
    */
    public String toString()
    {
        return "threadName:"+threadName+" "+
               "connection:"+connection+" "+
               "used:"+used+" "+
                "inTransaction:"+inTransaction+" "+
                "btime:"+beginTime;
    }
}