jdbccontext.java

一个完整的代码管理系统的源代码

/*
 * Copyright (c) 2007-2010 Tanming1003 Inc.
 * All rights reserved.
 * 
 * tanming1003<[e-mail]>
 * 
 * 
 * 
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions 
 * are met:
 * 
 * Redistributions of source code must retain the above copyright 
 * notice, this list of conditions and the following disclaimer. 
 * Redistributions in binary form must reproduce the above copyright 
 * notice, this list of conditions and the following disclaimer in the 
 * documentation and/or other materials provided with the distribution. 
 * Neither the name of tanming1003 nor the names of its contributors 
 * may be used to endorse or promote products derived from this 
 * software without specific prior written permission. 
 * 
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS 
 * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE 
 * REGENTS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, 
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, 
 * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 
 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER 
 * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, 
 * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING 
 * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 
 * POSSIBILITY OF SUCH DAMAGE.
 */
package hunnu.edu.cn.product.common.db;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;

import hunnu.edu.cn.product.log.LogFactory;
import hunnu.edu.cn.product.log.LogLog;

/**
 * @author tanming1003
 * @date 2008-10-10
 * @time 下午15:38:29
 * @project_name Product
 * @package_name hunnu.edu.cn.product.common.db
 * @file_name JdbcContext.java
 * @version 1.0
 */

public class JdbcContext extends Context
{
	private static final long serialVersionUID = 1175699589657642479L;
	private LogLog log = LogFactory.newInstance().getLog(this.getClass());
	private boolean isCommited;
	@SuppressWarnings("unused")
	private boolean isActived;
	private boolean isRollbacked;

	public JdbcContext()
	{
		super();
	}
	
	public JdbcContext(Connection connection)
	{
		super(connection);
	}

	public void commit()
	{
		if (!isCommited())
		{
			log.info("begin commit........");
			try
			{
				this.connection.commit();
			}
			catch (SQLException e)
			{
				e.printStackTrace();
			}
			setCommited(true);
			log.info("end commit..........");
			if(this.connection!=null)
			   closeConnection(connection);
		}
		return;
	}

	public boolean isActive()
	{
		return false;
	}

	public void rollback()
	{
		if (!isRollbacked())
		{
			
			setRollbacked(true);
			if(this.connection!=null)
			   closeConnection(connection);
		}
		return;
	}

	/**
	 * @return the isCommited
	 */
	public boolean isCommited()
	{
		return isCommited;
	}

	/**
	 * @param isCommited
	 *            the isCommited to set
	 */
	public void setCommited(boolean isCommited)
	{
		this.isCommited = isCommited;
	}

	/**
	 * @return the isActived
	 */
	public boolean isActived()
	{
		try
		{
			return connection.isClosed();
		}
		catch (SQLException e)
		{
			e.printStackTrace();
			return true;
		}
	}

	/**
	 * @param isActived
	 *            the isActived to set
	 */
	public void setActived(boolean isActived)
	{
		this.isActived = isActived;
	}

	/**
	 * @return the isRollbacked
	 */
	public boolean isRollbacked()
	{
		return isRollbacked;
	}

	/**
	 * @param isRollbacked
	 *            the isRollbacked to set
	 */
	public void setRollbacked(boolean isRollbacked)
	{
		this.isRollbacked = isRollbacked;
	}

	/**
	 * @return the serialVersionUID
	 */
	public static long getSerialVersionUID()
	{
		return serialVersionUID;
	}

	public void closeConnection(Connection connection)
	{
		try
		{
			DBProcess process=new DBWrapper();
			process.closeConnection(connection);
		}
		catch (Exception e)
		{
			log.debug("Exception:", e);
		}

	}

	public boolean deleteRecord(String sql, Object[] param) throws SQLException
	{
		try
		{
			DBProcess process=new DBWrapper();
			return process.deleteRecord(sql, param);
		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
		return false;
	}

	public boolean insertRecord(String sql, Object[] param) throws SQLException
	{
		DBProcess process=new DBWrapper();
		return process.insertRecord(sql, param);	
	}

	public List<?> queryRecord(String sql, Object[] param) throws SQLException
	{
		DBProcess process=new DBWrapper();
	    return process.queryRecord(sql, param);
		
	}

	public int updateRecord(String sql, Object[] param) throws SQLException
	{	
		DBProcess process=new DBWrapper();
		return process.updateRecord(sql, param);
	}
	
	public void delete(String sql)
	{
		try
		{
			DBProcess process=new DBWrapper();
			process.deleteRecord(sql);
		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
	}

	public void insert(String sql)
	{
		DBProcess process=new DBWrapper();
		try
		{
			process.insertRecord(sql);
		}
		catch (SQLException e)
		{
			e.printStackTrace();
		}
		
	}

	public List<?> query(String sql) 
	{
		try
		{
			DBProcess process=new DBWrapper();
			return process.queryRecord(sql);
		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
		return null;
	}
	
	public void update(String sql)
	{
        try
		{
        	DBProcess process=new DBWrapper();
			process.updateRecord(sql);
		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
	}
}