CscTransaction.java

/*
 * Created on 13 ¡.¾. 2550
 *
 * TODO To change the template for this generated file go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
package com.csc.library.database;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Iterator;

import com.csc.library.utilities.UProfile;

/**
 * @author Administrator
 *
 * TODO To change the template for this generated type comment go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
public class CscTransaction {
	private boolean rollback 	= false;
	private HashMap<String, CscConnection> connection 	= new HashMap<String, CscConnection>();
	public int beginTransactionKey	= 0; 
	public String userKey 					= "";
	
	public void rollback() throws SQLException {
		for (Iterator<String> it = connection.keySet().iterator(); it.hasNext();) {
			CscConnection con = connection.get(it.next());
			con.rollback();
			con.setCscTransaction(null);
			con.close();
		}
		connection.clear();
		this.rollback = true;
	}
	
	public void commit() throws SQLException {
		for (Iterator<String> it = connection.keySet().iterator(); it.hasNext();) {
			CscConnection con = connection.get(it.next());
//			con.commit();
			con.setCscTransaction(null);
			con.close();
		}
		connection.clear();
	}
	
	public void close() throws SQLException {
		for (Iterator<String> it = connection.keySet().iterator(); it.hasNext();) {
			CscConnection con = connection.get(it.next());
			con.setCscTransaction(null);
			con.close();
		}
		connection.clear();
	}
	
//  comment by pas à¹×èͧ¨Ò¡ 1 process 1 connection ·ÓãËéäÁèµéͧ stamp actiontime	
//	public void setActionTime()  {
//		for (Iterator<String> it = connection.keySet().iterator(); it.hasNext();) {
//			CscConnection con = connection.get(it.next());
//			con.setStarttime(System.currentTimeMillis());
//		}
//	}
	
	public CscConnection getConnection(String dbName, Object userKey) throws SQLException {
		CscConnection con = null;
		if (!this.isRollback()){
			String db = dbName.toLowerCase();
			if (connection.containsKey(db)) {
				con = connection.get(db); 
				if(con==null||(con!=null&&con.isClosed())){/** ¶éÒ connection ·Õè close ÃÐËÇèÒ§¡Ò÷ӧҹãËé·Ó¡Òà remove ·Ôé§ **/
				   if(con!=null){
					   con.closeAll();/**close connection ·Ôé§ä»¡Ã³Õ·ÕèÁѹäÁèÊÒÁÒöãªé§Ò¹connection ¹Ñé¹ä´é**/
					   con=null;
				   }
				   this.connection.remove(db);
				   con=getConnection(dbName,userKey);
			   }
			} else {
				/** 
				 * ¡Ã³Õ·ÕèÁÕ¡ÒÃÊÃéÒ§ connection ãËÁèãËéä»get ¨Ò¡ connectDB áÅéǶéÒà»ç¹ Connection process ¨Ð·Ó¡Òà setProcessid à¢éÒä»ÍÕ¡¤ÃÑé§ËÒ¡àÃÕ¡
				 * StaticProperties.myConnection.getConnection(db,userKey) ¨Ðà¡Ô´ recursive ËÒ¡äÁèset process id ¢Í§ process ÁռšѺ¡Ò÷ӧҹ¢Í§ connectionPools 
				*/
				con = (CscConnection) StaticProperties.myConnection.getConnection(db);
				synchronized(con) {
					UProfile up=(UProfile) userKey;
					if(up.getProcessid().length()>0){
						con.setProcessid(up.getProcessid());
					}
					this.connection.put(db, con);
					con.setAutoCommit(false);
					if(con.getTransactionIsolation()!=Connection.TRANSACTION_READ_UNCOMMITTED){
						con.setTransactionIsolation(Connection.TRANSACTION_READ_UNCOMMITTED);	
					}
					con.setUses(true);
					con.setCscTransaction(this);
				}	
			}
		}
		if(con!=null){
			con.setLasttime(System.currentTimeMillis());
		}
		return con;
	}
	
	public boolean isRollback() {
		return this.rollback;
	}

	public int getBeginTransactionKey() {
		return beginTransactionKey;
	}

	public void setBeginTransactionKey(int beginTransactionKey) {
		this.beginTransactionKey = beginTransactionKey;
	}

	public String getUserKey() {
		return userKey;
	}

	public void setUserKey(String userKey) {
		this.userKey = userKey;
	}
}