项目:ProyectoPacientes
文件:JDBC4CallableStatementWrapper.java
public sqlXML getsqlXML(int parameterIndex) throws sqlException {
try {
if (this.wrappedStmt != null) {
return ((CallableStatement) this.wrappedStmt).getsqlXML(parameterIndex);
} else {
throw sqlError.createsqlException("No operations allowed after statement closed",sqlError.sql_STATE_GENERAL_ERROR,this.exceptionInterceptor);
}
} catch (sqlException sqlEx) {
checkAndFireConnectionError(sqlEx);
}
return null;
}
项目:BibliotecaPS
文件:JDBC4ConnectionWrapper.java
项目:ProyectoPacientes
文件:JDBC4PreparedStatementHelper.java
static void setsqlXML(PreparedStatement pstmt,int parameterIndex,sqlXML xmlObject) throws sqlException {
if (xmlObject == null) {
pstmt.setNull(parameterIndex,Types.sqlXML);
} else {
// FIXME: Won't work for Non-MysqL sqlXMLs
pstmt.setCharacterStream(parameterIndex,((JDBC4MysqLsqlXML) xmlObject).serializeAsCharacterStream());
}
}
项目:the-vigilantes
文件:JDBC4CallableStatementWrapper.java
public void setsqlXML(int parameterIndex,sqlXML xmlObject) throws sqlException {
try {
if (this.wrappedStmt != null) {
((PreparedStatement) this.wrappedStmt).setsqlXML(parameterIndex,xmlObject);
} else {
throw sqlError.createsqlException("No operations allowed after statement closed",this.exceptionInterceptor);
}
} catch (sqlException sqlEx) {
checkAndFireConnectionError(sqlEx);
}
}
项目:the-vigilantes
文件:JDBC4CallableStatementWrapper.java
项目:the-vigilantes
文件:JDBC4CallableStatementWrapper.java
public sqlXML getsqlXML(String parameterName) throws sqlException {
try {
if (this.wrappedStmt != null) {
return ((CallableStatement) this.wrappedStmt).getsqlXML(parameterName);
} else {
throw sqlError.createsqlException("No operations allowed after statement closed",this.exceptionInterceptor);
}
} catch (sqlException sqlEx) {
checkAndFireConnectionError(sqlEx);
}
return null;
}
项目:ProyectoPacientes
文件:JDBC4CallableStatementWrapper.java
项目:BibliotecaPS
文件:JDBC4CallableStatementWrapper.java
项目:jdk8u-jdk
文件:StubJdbcRowSetImpl.java
项目:BibliotecaPS
文件:JDBC4UpdatableResultSet.java
项目:agroal
文件:MockResultSet.java
项目:spanner-jdbc
文件:AbstractCloudSpannerResultSet.java
项目:spanner-jdbc
文件:AbstractCloudSpannerPreparedStatement.java
项目:elastic-db-tools-for-java
文件:ValidationUtils.java
/**
* Performs validation that the local representation is as up-to-date as the representation on the backing data store.
*
* @param conn
* Connection used for validation.
* @param shardMapManager
* ShardMapManager reference.
* @param shardMap
* Shard map for the shard.
* @param shard
* Shard to validate.
*/
public static void validateShard(Connection conn,ShardMapManager shardMapManager,StoreShardMap shardMap,StoreShard shard) {
Stopwatch stopwatch = Stopwatch.createStarted();
StoreResults lsmResult = new StoreResults();
JAXBElement jaxbElement = StoreOperationRequestBuilder.validateShardLocal(shardMap.getId(),shard.getId(),shard.getVersion());
try (CallableStatement cstmt = conn.prepareCall(String.format("{call %s(?,?)}",StoreOperationRequestBuilder.SP_VALIDATE_SHARD_LOCAL))) {
sqlXML sqlxml = conn.createsqlXML();
JAXBContext context = JAXBContext.newInstance(StoreOperationInput.class,StoreShard.class,StoreShardMap.class);
// Set the result value from SAX events.
SAXResult sxResult = sqlxml.setResult(SAXResult.class);
context.createMarshaller().marshal(jaxbElement,sxResult);
/*
* log.info("Xml:{}\n{}","ValidateShardLocal",sqlStoreTransactionScope.asstring(context,jaxbElement));//
*/
cstmt.setsqlXML("input",sqlxml);
cstmt.registerOutParameter("result",Types.INTEGER);
Boolean hasResults = cstmt.execute();
StoreResults storeResults = sqlResults.newInstance(cstmt);
// After iterating resultSet's,get result integer.
int result = cstmt.getInt("result");
lsmResult.setResult(StoreResult.forValue(result));
stopwatch.stop();
log.info("Shard ValidateShard","Complete; Shard: {}; Connection: {}; Result: {}; Duration: {}",shard.getLocation(),conn.getMetaData().getURL(),lsmResult.getResult(),stopwatch.elapsed(TimeUnit.MILLISECONDS));
}
catch (sqlException | JAXBException e) {
e.printstacktrace();
}
if (lsmResult.getResult() != StoreResult.Success) {
if (lsmResult.getResult() == StoreResult.ShardMapDoesNotExist) {
shardMapManager.getCache().deleteShardMap(shardMap);
}
// Possible errors are:
// StoreResult.ShardMapDoesNotExist
// StoreResult.ShardDoesNotExist
// StoreResult.ShardVersionMismatch
// StoreResult.StoreversionMismatch
// StoreResult.MissingParametersForStoredProcedure
throw StoreOperationErrorHandler.onValidationErrorLocal(lsmResult,shardMap,"ValidateShard",StoreOperationRequestBuilder.SP_VALIDATE_SHARD_LOCAL);
}
}
项目:QDrill
文件:Drill2489CallsAfterCloseThrowExceptionsTest.java
项目:openjdk-jdk10
文件:StubCallableStatement.java
项目:BibliotecaPS
文件:JDBC4ResultSet.java
项目:Saturn
文件:SyncRS.java
项目:agroal
文件:ResultSetWrapper.java
项目:BibliotecaPS
文件:JDBC4Connection.java
项目:openjdk-jdk10
文件:StubCallableStatement.java
项目:openjdk-jdk10
文件:StubJoinRowSetImpl.java
项目:jdk8u-jdk
文件:StubJdbcRowSetImpl.java
项目:QDrill
文件:Drill2489CallsAfterCloseThrowExceptionsTest.java
项目:ProyectoPacientes
文件:JDBC4UpdatableResultSet.java
项目:blanco-sfdc-jdbc-driver
文件:BlancoGenericJdbcResultSet.java
项目:jdk8u-jdk
文件:StubJoinRowSetImpl.java
项目:nh-micro
文件:MicroPooledConnection.java
项目:jdk8u-jdk
文件:StubSyncResolver.java
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。