package jnpf.database.model.interfaces;

import jnpf.exception.DataException;

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

/**
 * 类功能
 *
 * @author JNPF开发平台组 YanYu
 * @version V3.4.2
 * @copyright 引迈信息技术有限公司
 * @date 2022/8/17 0017
 */
@FunctionalInterface
public interface JdbcCreUpDel<T> {

    T execute() throws SQLException;

    /**
     * 参数配置
     */
    static void setData(PreparedStatement preparedStatement, List<?> data) throws SQLException {
        if(data != null){
            for (int i = 0; i < data.size(); i++) {
                preparedStatement.setObject(i + 1, data.get(i));
            }
        }
    }

    static <T>T get(Connection conn, JdbcCreUpDel<T> creUpDel) throws SQLException {
        try{
            conn.setAutoCommit(false);
            T result= creUpDel.execute();
            conn.commit();
            return result;
        } catch (SQLException e) {
            //捕捉回滚操作
            throw DataException.rollbackDataException(e, conn);
        }
    }

}