transactionmanager.java

来自「信息发布 发布系统 动态的菜单 和 信息统计」· Java 代码 · 共 108 行

/**
 * 
 */
package com.xuntian.material.data.idao;

import java.sql.ResultSet;
import java.sql.Savepoint;
import java.util.List;

import com.xuntian.material.exception.ConnectPoolException;

public interface TransactionManager {
    /**
     * 事务开始
     */
    public void begin() throws ConnectPoolException;

    /**
     * 事物提交
     */
    public void commit() throws ConnectPoolException;

    /**
     * 事务回滚
     */
    public void rollback() throws ConnectPoolException;

    /**
     * @return Savepoint
     */
    public Savepoint addSavePoint() throws ConnectPoolException;
    /**
     * 设置是否自动提交
     * 
     * @param isAuto
     *            true:auto false:NOT auto
     */
    public void setAutoCommit(boolean isAuto) throws ConnectPoolException;
    /**
     * 设置是否自动事务
     * 
     * @param isAuto
     *            true:auto false:NOT auto
     */
    public void setAutoTransaction(boolean isAutoTransaction) throws ConnectPoolException;
    /**
     * 手动控制事务时候释放连接进入连接池
     * @param conn
     * @throws ConnectPoolException
     */
    public void freeConn() throws ConnectPoolException;
    /**
     * @param sql
     * @return insert rows; update rows;delete rows;
     */
    public int executeUpdate(String sql) throws ConnectPoolException;

    /**
     * @param sql
     * @return insert rows; update rows;delete rows;
     */
    public int executeUpdate(List<String> sqlList) throws ConnectPoolException;

    /**
     * @param sql
     * @return the query resultSet
     */
    public ResultSet executeQuery(String sql) throws ConnectPoolException;

    /**
     * @param sql
     * @return insert rows; update rows;delete rows;
     */
    public int executeUpdate(String sql, List<String> parameterList) throws ConnectPoolException;

    /**
     * @param sql
     * @return insert rows; update rows;delete rows;
     */
    public int executeUpdate(List<String> sqlList, List<List<String>> parametersList) throws ConnectPoolException;

    /**
     * @param sql
     * @return the query resultSet
     */
    public ResultSet executeQuery(String sql, List<String> parameterList) throws ConnectPoolException;
    /**
     * @param sql
     * @return 格式化的传入页面table的list
     * @throws ConnectPoolException
     */
    public List<List<String>> query(String sql) throws ConnectPoolException;
    /**
     * @param sql
     * @param parameterList
     * @return 格式化的传入页面table的list
     * @throws ConnectPoolException
     */
    public List<List<String>> query(String sql,List<String> parameterList) throws ConnectPoolException ;
    /**
     * @param clazz
     * @param rs
     * @return  判断结果集合是否有数据
     * @throws ConnectPoolException
     */
    public boolean isResultNull(Class clazz,ResultSet rs) ;
}