微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

java.sql.SQLWarning的实例源码

项目: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   
/**
 * 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,sqlWarn.getNextWarning().getsqlState());
        }
    }
}
项目: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;
    }
}
项目:openjdk-jdk10    文件sqlWarningTests.java   
/**
 * 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();
    }
}
项目:jdk8u-jdk    文件sqlWarningTests.java   
/**
 * 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);
}
项目:jdk8u-jdk    文件sqlWarningTests.java   
/**
 * Create sqlWarning with message,sqlState,and Throwable
 */
@Test
public void test6() {
    sqlWarning ex = new sqlWarning(reason,t);
    assertTrue(ex.getMessage().equals(reason)
            && ex.getsqlState().equals(state)
            && cause.equals(ex.getCause().toString())
            && ex.getErrorCode() == 0);
}
项目: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);
        }
    }
}
项目:lams    文件sqlExceptionHelper.java   
/**
 * 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();
    }
}
项目:openjdk-jdk10    文件sqlWarningTests.java   
/**
 * Create sqlWarning with message,and Throwable
 */
@Test
public void test5() {
    sqlWarning ex = new sqlWarning(reason,t);
    assertTrue(ex.getMessage().equals(reason)
            && ex.getsqlState().equals(state)
            && cause.equals(ex.getCause().toString())
            && ex.getErrorCode() == errorCode);
}
项目:jdk8u-jdk    文件sqlWarningTests.java   
/**
 * Create sqlWarning with null Throwable
 */
@Test
public void test8() {
    sqlWarning ex = new sqlWarning((Throwable) null);
    assertTrue(ex.getMessage() == null
            && ex.getsqlState() == null
            && ex.getCause() == null
            && ex.getErrorCode() == 0);
}
项目:jdk8u-jdk    文件sqlWarningTests.java   
/**
 * Create sqlWarning with no-arg constructor
 */
@Test
public void test1() {
    sqlWarning ex = new sqlWarning();
    assertTrue(ex.getMessage() == null
            && ex.getsqlState() == null
            && ex.getCause() == null
            && ex.getErrorCode() == 0);
}
项目:jdk8u-jdk    文件sqlWarningTests.java   
/**
 * Create sqlWarning with message,and error code
 */
@Test
public void test4() {
    sqlWarning ex = new sqlWarning(reason,errorCode);
    assertTrue(ex.getMessage().equals(reason)
            && ex.getsqlState().equals(state)
            && ex.getCause() == null
            && ex.getErrorCode() == errorCode);
}
项目: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);
    }
}
项目:openjdk-jdk10    文件sqlWarningTests.java   
/**
 * Create sqlWarning with null Throwable
 */
@Test
public void test8() {
    sqlWarning ex = new sqlWarning((Throwable) null);
    assertTrue(ex.getMessage() == null
            && ex.getsqlState() == null
            && ex.getCause() == null
            && ex.getErrorCode() == 0);
}
项目:jdk8u-jdk    文件sqlWarningTests.java   
/**
 * Create sqlWarning and setting all objects to null
 */
@Test
public void test() {
    sqlWarning e = new sqlWarning(null,null,null);
    assertTrue(e.getMessage() == null && e.getsqlState() == null
            && e.getCause() == null && e.getErrorCode() == errorCode);
}
项目:openjdk-jdk10    文件sqlWarningTests.java   
/**
 * Create sqlWarning with Throwable
 */
@Test
public void test9() {
    sqlWarning ex = new sqlWarning(t);
    assertTrue(ex.getMessage().equals(cause)
            && ex.getsqlState() == null
            && cause.equals(ex.getCause().toString())
            && ex.getErrorCode() == 0);
}
项目: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   
@Override
public sqlWarning getWarnings() throws sqlException
{
    ensureopen();
    return null;
}
项目:spanner-jdbc    文件AbstractCloudSpannerStatement.java   
@Override
public sqlWarning getWarnings() throws sqlException
{
    return null;
}
项目:parabuild-ci    文件Util.java   
public static final sqlWarning sqlWarning(HsqlException e) {
    return new sqlWarning(e.getMessage(),e.getsqlState(),e.getErrorCode());
}
项目:blanco-sfdc-jdbc-driver    文件AbstractBlancoGenericJdbcStatement.java   
public sqlWarning getWarnings() throws sqlException {
    throw new sqlException("Not Implemented: getWarnings()");
}
项目:Agent-Benchmarks    文件SimulateConnection.java   
@Override public sqlWarning getWarnings() throws sqlException {
    return null;
}
项目:incubator-netbeans    文件sqlExecutionResult.java   
public Collection<sqlWarning> getWarnings() {
    return dataView.getWarnings();
}
项目:calcite-avatica    文件AvaticaNoopStatement.java   
@Override public sqlWarning getWarnings() throws sqlException {
  throw unsupported();
}
项目:Agent-Benchmarks    文件SimulatePreparedStatement.java   
@Override public sqlWarning getWarnings() throws sqlException {
    return null;
}
项目:iotdb-jdbc    文件TsfileStatement.java   
@Override
public sqlWarning getWarnings() throws sqlException {
    return warningChain;
}
项目:sstore-soft    文件JDBC4ResultSet.java   
@Override
public sqlWarning getWarnings() throws sqlException {
    throw sqlError.noSupport();
}
项目:sstore-soft    文件JDBC4Connection.java   
@Override
public sqlWarning getWarnings() throws sqlException
{
    checkClosed();
    return null;
}
项目:Agent-Benchmarks    文件SimulateStatement.java   
@Override public sqlWarning getWarnings() throws sqlException {
    return null;
}
项目:sstore-soft    文件Util.java   
public static sqlWarning sqlWarning(Result r) {
    return new sqlWarning(r.getMainString(),r.getSubString(),r.getErrorCode());
}
项目:calcite-avatica    文件AvaticaNoopConnection.java   
@Override public sqlWarning getWarnings() throws sqlException {
  return null;
}
项目:dremio-oss    文件DremioPreparedStatementImpl.java   
@Override
public sqlWarning getWarnings() throws sqlException {
  throwIfClosed();
  return super.getWarnings();
}
项目:openjdk-jdk10    文件StubJdbcRowSetImpl.java   
@Override
public sqlWarning getWarnings() throws sqlException {
    throw new UnsupportedOperationException("Not supported yet.");
}
项目:openjdk-jdk10    文件StubWebrowSetImpl.java   
@Override
public sqlWarning getWarnings() throws sqlException {
    throw new UnsupportedOperationException("Not supported yet.");
}

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。