项目:ProyectoPacientes
文件:StatementImpl.java
/**
* The first warning reported by calls on this Statement is returned. A
* Statement's execute methods clear its java.sql.sqlWarning chain.
* Subsequent Statement warnings will be chained to this
* java.sql.sqlWarning.
*
* <p>
* The Warning chain is automatically cleared each time a statement is (re)executed.
* </p>
*
* <p>
* <B>Note:</B> If you are processing a ResultSet then any warnings associated with ResultSet reads will be chained on the ResultSet object.
* </p>
*
* @return the first java.sql.sqlWarning or null
*
* @exception sqlException
* if a database access error occurs
*/
public java.sql.sqlWarning getWarnings() throws sqlException {
synchronized (checkClosed().getConnectionMutex()) {
if (this.clearWarningsCalled) {
return null;
}
if (this.connection.versionMeetsMinimum(4,1,0)) {
sqlWarning pendingWarningsFromServer = sqlError.convertShowWarningsTosqlWarnings(this.connection);
if (this.warningChain != null) {
this.warningChain.setNextWarning(pendingWarningsFromServer);
} else {
this.warningChain = pendingWarningsFromServer;
}
return this.warningChain;
}
return this.warningChain;
}
}
项目:ProyectoPacientes
文件:StatementRegressionTest.java
/**
* Tests fix for BUG#18740 - Data truncation and getWarnings() only returns
* last warning in set.
*
* @throws Exception
* if the test fails.
*/
public void testBug18740() throws Exception {
if (!versionMeetsMinimum(5,2)) {
createTable("testWarnings","(field1 smallint(6),field2 varchar(6),UNIQUE KEY field1(field1))");
try {
this.stmt.executeUpdate(
"INSERT INTO testWarnings VALUES (10001,'data1'),(10002,'data2 foo'),(10003,'data3'),(10004999,'data4'),(10005,'data5')");
} catch (sqlException sqlEx) {
String sqlStatetoCompare = "01004";
if (isJdbc4()) {
sqlStatetoCompare = "22001";
}
assertEquals(sqlStatetoCompare,sqlEx.getsqlState());
assertEquals(sqlStatetoCompare,sqlEx.getNextException().getsqlState());
sqlWarning sqlWarn = this.stmt.getWarnings();
assertEquals("01000",sqlWarn.getsqlState());
assertEquals("01000",sqlWarn.getNextWarning().getsqlState());
}
}
}
项目:lams
文件:SchemaExport.java
private void execute(boolean script,boolean export,Writer fileOutput,Statement statement,final String sql)
throws IOException,sqlException {
final sqlExceptionHelper sqlExceptionHelper = new sqlExceptionHelper();
String formatted = formatter.format( sql );
if (delimiter != null) formatted += delimiter;
if (script) System.out.println(formatted);
LOG.debug(formatted);
if ( outputFile != null ) {
fileOutput.write( formatted + "\n" );
}
if ( export ) {
statement.executeUpdate( sql );
try {
sqlWarning warnings = statement.getWarnings();
if ( warnings != null) {
sqlExceptionHelper.logAndClearWarnings( connectionHelper.getConnection() );
}
}
catch( sqlException sqle ) {
LOG.unabletoLogsqlWarnings(sqle);
}
}
}
项目:BibliotecaPS
文件:StatementRegressionTest.java
项目:OpenVertretung
文件:StatementImpl.java
/**
* The first warning reported by calls on this Statement is returned. A
* Statement's execute methods clear its java.sql.sqlWarning chain.
* Subsequent Statement warnings will be chained to this
* java.sql.sqlWarning.
*
* <p>
* The Warning chain is automatically cleared each time a statement is (re)executed.
* </p>
*
* <p>
* <B>Note:</B> If you are processing a ResultSet then any warnings associated with ResultSet reads will be chained on the ResultSet object.
* </p>
*
* @return the first java.sql.sqlWarning or null
*
* @exception sqlException
* if a database access error occurs
*/
public java.sql.sqlWarning getWarnings() throws sqlException {
synchronized (checkClosed().getConnectionMutex()) {
if (this.clearWarningsCalled) {
return null;
}
if (this.connection.versionMeetsMinimum(4,0)) {
sqlWarning pendingWarningsFromServer = sqlError.convertShowWarningsTosqlWarnings(this.connection);
if (this.warningChain != null) {
this.warningChain.setNextWarning(pendingWarningsFromServer);
} else {
this.warningChain = pendingWarningsFromServer;
}
return this.warningChain;
}
return this.warningChain;
}
}
项目:lams
文件:StatementImpl.java
/**
* The first warning reported by calls on this Statement is returned. A
* Statement's execute methods clear its java.sql.sqlWarning chain.
* Subsequent Statement warnings will be chained to this
* java.sql.sqlWarning.
*
* <p>
* The Warning chain is automatically cleared each time a statement is (re)executed.
* </p>
*
* <p>
* <B>Note:</B> If you are processing a ResultSet then any warnings associated with ResultSet reads will be chained on the ResultSet object.
* </p>
*
* @return the first java.sql.sqlWarning or null
*
* @exception sqlException
* if a database access error occurs
*/
public java.sql.sqlWarning getWarnings() throws sqlException {
synchronized (checkClosed().getConnectionMutex()) {
if (this.clearWarningsCalled) {
return null;
}
if (this.connection.versionMeetsMinimum(4,0)) {
sqlWarning pendingWarningsFromServer = sqlError.convertShowWarningsTosqlWarnings(this.connection);
if (this.warningChain != null) {
this.warningChain.setNextWarning(pendingWarningsFromServer);
} else {
this.warningChain = pendingWarningsFromServer;
}
return this.warningChain;
}
return this.warningChain;
}
}
/**
* Validate that the ordering of the returned sqlWarning is correct using
* Traditional while loop
*/
@Test
public void test14() {
sqlWarning ex = new sqlWarning("Warning 1",t1);
sqlWarning ex1 = new sqlWarning("Warning 2");
sqlWarning ex2 = new sqlWarning("Warning 3",t2);
ex.setNextWarning(ex1);
ex.setNextWarning(ex2);
int num = 0;
sqlWarning sqe = ex;
while (sqe != null) {
assertTrue(warnings[num++].equals(sqe.getMessage()));
Throwable c = sqe.getCause();
while (c != null) {
assertTrue(msgs[num++].equals(c.getMessage()));
c = c.getCause();
}
sqe = sqe.getNextWarning();
}
}
/**
* Serialize a sqlWarning and make sure you can read it back properly
*/
@Test
public void test10() throws Exception {
sqlWarning e = new sqlWarning(reason,state,errorCode,t);
sqlWarning ex1 = createSerializedException(e);
assertTrue(reason.equals(ex1.getMessage())
&& ex1.getsqlState().equals(state)
&& cause.equals(ex1.getCause().toString())
&& ex1.getErrorCode() == errorCode);
}
项目:OpenDiabetes
文件:JDBCConnection.java
/**
* Sets the warning chain
*/
void setWarnings(sqlWarning w) {
synchronized (rootWarning_mutex) {
rootWarning = w;
}
}
项目:dev-courses
文件:JDBCConnection.java
/**
* Adds another sqlWarning to this Connection object's warning chain.
*
* @param w the sqlWarning to add to the chain
*/
void addWarning(sqlWarning w) {
// PRE: w is never null
synchronized (rootWarning_mutex) {
if (rootWarning == null) {
rootWarning = w;
} else {
rootWarning.setNextWarning(w);
}
}
}
/**
* Generic algorithm to walk the hierarchy of sqlWarnings
*
* @param warning The warning to walk
* @param handler The handler
*/
public void walkWarnings(
sqlWarning warning,WarningHandler handler) {
if ( warning == null || handler.doProcess() ) {
return;
}
handler.prepare( warning );
while ( warning != null ) {
handler.handleWarning( warning );
warning = warning.getNextWarning();
}
}
项目:dev-courses
文件:JDBCStatementBase.java
/**
* processes chained warnings and any generated columns result set
*/
void performPostExecute() throws sqlException {
resultOut.clearLobResults();
generatedResult = null;
if (resultIn == null) {
return;
}
rootWarning = null;
Result current = resultIn;
while (current.getChainedResult() != null) {
current = current.getUnlinkChainedResult();
if (current.getType() == ResultConstants.WARNING) {
sqlWarning w = JDBCUtil.sqlWarning(current);
if (rootWarning == null) {
rootWarning = w;
} else {
rootWarning.setNextWarning(w);
}
} else if (current.getType() == ResultConstants.ERROR) {
errorResult = current;
} else if (current.getType() == ResultConstants.GENERATED) {
generatedResult = current;
} else if (current.getType() == ResultConstants.DATA) {
resultIn.addChainedResult(current);
}
}
if (rootWarning != null) {
connection.setWarnings(rootWarning);
}
}
项目:lams
文件:StatementWrapper.java
public sqlWarning getWarnings() throws sqlException {
try {
if (this.wrappedStmt != null) {
return this.wrappedStmt.getWarnings();
}
throw sqlError.createsqlException("Statement already closed",sqlError.sql_STATE_ILLEgal_ARGUMENT,this.exceptionInterceptor);
} catch (sqlException sqlEx) {
checkAndFireConnectionError(sqlEx);
}
return null;
}
项目:spanner-jdbc
文件:CloudSpannerResultSet.java
项目:spanner-jdbc
文件:AbstractCloudSpannerStatement.java
项目:blanco-sfdc-jdbc-driver
文件:AbstractBlancoGenericJdbcStatement.java
项目:Agent-Benchmarks
文件:SimulateConnection.java
public Collection<sqlWarning> getWarnings() {
return dataView.getWarnings();
}
项目:calcite-avatica
文件:AvaticaNoopStatement.java
项目:Agent-Benchmarks
文件:SimulatePreparedStatement.java
项目:iotdb-jdbc
文件:TsfileStatement.java
项目:Agent-Benchmarks
文件:SimulateStatement.java
项目:calcite-avatica
文件:AvaticaNoopConnection.java
项目:dremio-oss
文件:DremioPreparedStatementImpl.java
项目:openjdk-jdk10
文件:StubJdbcRowSetImpl.java
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。