大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。
Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺
/*** Copyright 2009-2016 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the “License”);
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
*http://www.apache.org/licenses/LICENSE-2.0*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an “AS IS” BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.*/
packageorg.apache.ibatis.executor.statement;importjava.sql.Connection;importjava.sql.SQLException;importjava.sql.Statement;importorg.apache.ibatis.executor.ErrorContext;importorg.apache.ibatis.executor.Executor;importorg.apache.ibatis.executor.ExecutorException;importorg.apache.ibatis.executor.keygen.KeyGenerator;importorg.apache.ibatis.executor.parameter.ParameterHandler;importorg.apache.ibatis.executor.resultset.ResultSetHandler;importorg.apache.ibatis.mapping.BoundSql;importorg.apache.ibatis.mapping.MappedStatement;importorg.apache.ibatis.reflection.factory.ObjectFactory;importorg.apache.ibatis.session.Configuration;importorg.apache.ibatis.session.ResultHandler;importorg.apache.ibatis.session.RowBounds;importorg.apache.ibatis.type.TypeHandlerRegistry;/***@authorClinton Begin*/
public abstract class BaseStatementHandler implementsStatementHandler {protected finalConfiguration configuration;protected finalObjectFactory objectFactory;protected finalTypeHandlerRegistry typeHandlerRegistry;protected finalResultSetHandler resultSetHandler;protected finalParameterHandler parameterHandler;protected finalExecutor executor;protected finalMappedStatement mappedStatement;protected finalRowBounds rowBounds;protectedBoundSql boundSql;protectedBaseStatementHandler(Executor executor, MappedStatement mappedStatement, Object parameterObject, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) {this.configuration =mappedStatement.getConfiguration();this.executor =executor;this.mappedStatement =mappedStatement;this.rowBounds =rowBounds;this.typeHandlerRegistry =configuration.getTypeHandlerRegistry();this.objectFactory =configuration.getObjectFactory();if (boundSql == null) { //issue #435, get the key before calculating the statement
generateKeys(parameterObject);
boundSql=mappedStatement.getBoundSql(parameterObject);
}this.boundSql =boundSql;this.parameterHandler =configuration.newParameterHandler(mappedStatement, parameterObject, boundSql);this.resultSetHandler =configuration.newResultSetHandler(executor, mappedStatement, rowBounds, parameterHandler, resultHandler, boundSql);
}
@OverridepublicBoundSql getBoundSql() {returnboundSql;
}
@OverridepublicParameterHandler getParameterHandler() {returnparameterHandler;
}
@Overridepublic Statement prepare(Connection connection, Integer transactionTimeout) throwsSQLException {
ErrorContext.instance().sql(boundSql.getSql());
Statement statement= null;try{
statement=instantiateStatement(connection);
setStatementTimeout(statement, transactionTimeout);
setFetchSize(statement);returnstatement;
}catch(SQLException e) {
closeStatement(statement);throwe;
}catch(Exception e) {
closeStatement(statement);throw new ExecutorException(“Error preparing statement. Cause: ” +e, e);
}
}protected abstract Statement instantiateStatement(Connection connection) throwsSQLException;protected void setStatementTimeout(Statement stmt, Integer transactionTimeout) throwsSQLException {
Integer queryTimeout= null;if (mappedStatement.getTimeout() != null) {
queryTimeout=mappedStatement.getTimeout();
}else if (configuration.getDefaultStatementTimeout() != null) {
queryTimeout=configuration.getDefaultStatementTimeout();
}if (queryTimeout != null) {
stmt.setQueryTimeout(queryTimeout);
}
StatementUtil.applyTransactionTimeout(stmt, queryTimeout, transactionTimeout);
}protected void setFetchSize(Statement stmt) throwsSQLException {
Integer fetchSize=mappedStatement.getFetchSize();if (fetchSize != null) {
stmt.setFetchSize(fetchSize);return;
}
Integer defaultFetchSize=configuration.getDefaultFetchSize();if (defaultFetchSize != null) {
stmt.setFetchSize(defaultFetchSize);
}
}protected voidcloseStatement(Statement statement) {try{if (statement != null) {
statement.close();
}
}catch(SQLException e) {//ignore
}
}protected voidgenerateKeys(Object parameter) {
KeyGenerator keyGenerator=mappedStatement.getKeyGenerator();
ErrorContext.instance().store();
keyGenerator.processBefore(executor, mappedStatement,null, parameter);
ErrorContext.instance().recall();
}
}
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/195780.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...