daomanager.java

JSP+AJAX开发的聊天室(毕业设计)

package org.yeeku.dao;

import java.sql.Connection;
import java.sql.SQLException;
import javax.sql.DataSource;
import org.yeeku.dao.*;
import zuojie.esql.ESQL;


public class DaoManager
{
	private static ESQL esql;
	public static int READ_COMMITTED = Connection.TRANSACTION_READ_COMMITTED;
	public static int SERIALIZABLE = Connection.TRANSACTION_SERIALIZABLE;

	public void setEsql(ESQL esql)
	{
		this.esql = esql;
	}

	/*开始事务 */
	public static void begin(int isolation) throws Exception
	{
		try
		{
			esql.startTransaction(isolation);
		}
		catch (Exception e)
		{
			throw new Exception("开始事务错误", e);
		}
	}

	public static void begin() throws Exception
	{
		begin(DaoManager.READ_COMMITTED);
	}

	/* 提交当前事务 */
	public static void commit() throws Exception
	{
		try
		{
			esql.commitTransaction();
		}
		catch (Exception e)
		{
			throw new Exception("提交事务错误", e);
		}
	}

	/* 结束当前事务。如果没有提交，就回滚 */
	public static void end()
	{
		try
		{
			esql.endTransaction();
		}
		catch (Exception e)
		{
		}
	}

	public static void setTransactionIsolation(int isolation) throws Exception
	{
		try
		{
			esql.setTransactionIsolation(isolation);
		}
		catch (SQLException e)
		{
			throw new Exception("设置事务隔离度错误", e);
		}
	}
}