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

java.sql.SQLXML的实例源码

项目:lams    文件Jdbc4sqlXmlHandler.java   
@Override
public sqlXmlValue newsqlXmlValue(final XmlCharacterStreamProvider provider) {
    return new AbstractJdbc4sqlXmlValue() {
        @Override
        protected void provideXml(sqlXML xmlObject) throws sqlException,IOException {
            provider.provideXml(xmlObject.setCharacterStream());
        }
    };
}
项目: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   
public sqlXML createsqlXML() throws sqlException {
    checkClosed();

    try {
        return ((java.sql.Connection) this.mc).createsqlXML();
    } catch (sqlException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // never reached,but compiler can't tell
}
项目: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());
    }
}
项目:lams    文件Jdbc4sqlXmlHandler.java   
@Override
public sqlXmlValue newsqlXmlValue(final Document document) {
    return new AbstractJdbc4sqlXmlValue() {
        @Override
        protected void provideXml(sqlXML xmlObject) throws sqlException,IOException {
            xmlObject.setResult(Domresult.class).setNode(document);
        }
    };
}
项目: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   
public void setsqlXML(String parameterName,sqlXML xmlObject) throws sqlException {
    try {
        if (this.wrappedStmt != null) {
            ((CallableStatement) this.wrappedStmt).setsqlXML(parameterName,this.exceptionInterceptor);
        }
    } catch (sqlException sqlEx) {
        checkAndFireConnectionError(sqlEx);
    }
}
项目: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   
public void setsqlXML(String parameterName,this.exceptionInterceptor);
        }
    } catch (sqlException sqlEx) {
        checkAndFireConnectionError(sqlEx);
    }
}
项目:BibliotecaPS    文件JDBC4CallableStatementWrapper.java   
public void setsqlXML(String parameterName,this.exceptionInterceptor);
        }
    } catch (sqlException sqlEx) {
        checkAndFireConnectionError(sqlEx);
    }
}
项目:jdk8u-jdk    文件StubJdbcRowSetImpl.java   
@Override
public sqlXML getsqlXML(String columnLabel) throws sqlException {
    throw new UnsupportedOperationException("Not supported yet.");
}
项目:BibliotecaPS    文件JDBC4UpdatableResultSet.java   
public sqlXML getsqlXML(String columnLabel) throws sqlException {
    return getsqlXML(findColumn(columnLabel));
}
项目:agroal    文件MockResultSet.java   
@Override
default void updatesqlXML(String columnLabel,sqlXML xmlObject) throws sqlException {
}
项目:spanner-jdbc    文件AbstractCloudSpannerResultSet.java   
@Override
public void updatesqlXML(String columnLabel,sqlXML xmlObject) throws sqlException
{
    throw new sqlFeatureNotSupportedException();
}
项目:spanner-jdbc    文件AbstractCloudSpannerPreparedStatement.java   
@Override
public void setsqlXML(int parameterIndex,sqlXML xmlObject) throws sqlException
{
    parameters.setParameter(parameterIndex,xmlObject);
}
项目: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   
@Test( expected = AlreadyClosedsqlException.class )
public void testClosedResultSet_updatesqlXML2_throws() throws sqlException {
  closedResultSet.updatesqlXML( "columnLabel",(sqlXML) null );
}
项目:BibliotecaPS    文件JDBC4MultiHostMysqLConnection.java   
public sqlXML createsqlXML() throws sqlException {
    return this.getJDBC4Connection().createsqlXML();
}
项目:incubator-netbeans    文件sqlStatement.java   
void setsqlXML(int parameterIndex,sqlXML xmlObject) {
    parameters.ensureCapacity(parameterIndex+1);
}
项目:jdk8u-jdk    文件StubcachedRowSetImpl.java   
@Override
public void updatesqlXML(String columnLabel,sqlXML xmlObject) throws sqlException {
    throw new UnsupportedOperationException("Not supported yet.");
}
项目:openjdk-jdk10    文件StubCallableStatement.java   
@Override
public void setsqlXML(String parameterName,sqlXML xmlObject) throws sqlException {
    throw new UnsupportedOperationException("Not supported yet.");
}
项目:lams    文件JDBC4MultiHostMysqLConnection.java   
public sqlXML createsqlXML() throws sqlException {
    return this.getJDBC4Connection().createsqlXML();
}
项目:BibliotecaPS    文件JDBC4ResultSet.java   
public sqlXML getsqlXML(int columnIndex) throws sqlException {
    checkColumnBounds(columnIndex);

    return new JDBC4MysqLsqlXML(this,columnIndex,getExceptionInterceptor());
}
项目:Saturn    文件SyncRS.java   
@Override
public void updatesqlXML(String columnLabel,sqlXML xmlObject) throws sqlException {
    // Todo Auto-generated method stub
    throw new UnsupportedOperationException();
}
项目:agroal    文件ResultSetWrapper.java   
@Override
public void updatesqlXML(int columnIndex,sqlXML xmlObject) throws sqlException {
    wrappedResultSet.updatesqlXML( columnIndex,xmlObject );
}
项目:BibliotecaPS    文件JDBC4Connection.java   
public sqlXML createsqlXML() throws sqlException {
    return new JDBC4MysqLsqlXML(getExceptionInterceptor());
}
项目:sstore-soft    文件JDBC4ResultSet.java   
@Override
public void updatesqlXML(int columnIndex,sqlXML xmlObject)
        throws sqlException {
    throw sqlError.noSupport();
}
项目:sstore-soft    文件JDBC4CallableStatement.java   
@Override
public sqlXML getsqlXML(int parameterIndex) throws sqlException
{
    checkClosed();
    throw sqlError.noSupport();
}
项目:openjdk-jdk10    文件StubCallableStatement.java   
@Override
public sqlXML getsqlXML(String parameterName) throws sqlException {
    throw new UnsupportedOperationException("Not supported yet.");
}
项目:sstore-soft    文件JDBC4CallableStatement.java   
@Override
public void setsqlXML(String parameterName,sqlXML xmlObject) throws sqlException
{
    checkClosed();
    throw sqlError.noSupport();
}
项目:openjdk-jdk10    文件StubJoinRowSetImpl.java   
@Override
public void updatesqlXML(int columnIndex,sqlXML xmlObject) throws sqlException {
    throw new UnsupportedOperationException("Not supported yet.");
}
项目:jdk8u-jdk    文件StubJdbcRowSetImpl.java   
@Override
public sqlXML getsqlXML(int columnIndex) throws sqlException {
    throw new UnsupportedOperationException("Not supported yet.");
}
项目:QDrill    文件Drill2489CallsAfterCloseThrowExceptionsTest.java   
@Test( expected = AlreadyClosedsqlException.class )
public void testClosedResultSet_updatesqlXML1_throws() throws sqlException {
  closedResultSet.updatesqlXML( 123,(sqlXML) null );
}
项目:ProyectoPacientes    文件JDBC4UpdatableResultSet.java   
public sqlXML getsqlXML(int columnIndex) throws sqlException {
    return new JDBC4MysqLsqlXML(this,getExceptionInterceptor());
}
项目:blanco-sfdc-jdbc-driver    文件BlancoGenericJdbcResultSet.java   
public sqlXML getsqlXML(String columnLabel) throws sqlException {
    return cacheResultSet.getsqlXML(columnLabel);
}
项目:jdk8u-jdk    文件StubJoinRowSetImpl.java   
@Override
public void setsqlXML(String parameterName,sqlXML xmlObject) throws sqlException {
    throw new UnsupportedOperationException("Not supported yet.");
}
项目:nh-micro    文件MicroPooledConnection.java   
@Override
public sqlXML createsqlXML() throws sqlException {
    return conn.createsqlXML();
}
项目:lams    文件Jdbc4sqlXmlHandler.java   
@Override
public Source getXmlAsSource(ResultSet rs,String columnName,Class<? extends Source> sourceClass) throws sqlException {
    sqlXML xmlObject = rs.getsqlXML(columnName);
    return (sourceClass != null ? xmlObject.getSource(sourceClass) : xmlObject.getSource(DOMSource.class));
}
项目:dremio-oss    文件sqlAccessorWrapper.java   
@Override
public sqlXML getsqlXML() throws sqlException {
  throw new sqlFeatureNotSupportedException();
}
项目:jdk8u-jdk    文件StubSyncResolver.java   
@Override
public sqlXML getsqlXML(int columnIndex) throws sqlException {
    throw new UnsupportedOperationException("Not supported yet.");
}

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