本文整理汇总了Java中oracle.sql.CLOB类的典型用法代码示例。如果您正苦于以下问题:Java CLOB类的具体用法?Java CLOB怎么用?Java CLOB使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
CLOB类属于oracle.sql包,在下文中一共展示了CLOB类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: exportFile
import oracle.sql.CLOB; //导入依赖的package包/类
/**
* Método responsável pela exportação de aplicação
*
* @since APEX 3 Parcial
* @since APEX 4 Parcial
* @since APEX 5
* @throws java.sql.SQLException
* @throws java.io.IOException
*/
private void exportFile() throws SQLException, IOException {
String vFileName;
CLOB vClob = getFile();
BigDecimal vCount = new BigDecimal(1);
Connection vConn = getConn();
try (PreparedStatement vPS = vConn.prepareStatement(getStmt(IS_WORKSPACE))) {
vPS.setBigDecimal(1, getApplicationId());
try (ResultSet vRS = vPS.executeQuery()) {
while (vRS.next()) {
vCount = vRS.getBigDecimal(1);
}
}
}
vFileName = vCount == new BigDecimal(0) ? "f" + getApplicationId() + ".sql" : "ws" + getApplicationId() + ".sql";
writeClobToFile(vClob, vFileName);
}
开发者ID:FwMontadorVersaoDevTeam,项目名称:ApexExporter,代码行数:26,代码来源:Exporter.java
示例2: getFile
import oracle.sql.CLOB; //导入依赖的package包/类
/**
* Método responsável pela extração de aplicação
*
* @since APEX 3 Parcial
* @since APEX 4 Parcial
* @since APEX 5
* @return Aplicação
* @throws java.sql.SQLException
* @throws java.io.IOException
*/
private CLOB getFile() throws SQLException, IOException {
CLOB vClob;
Connection vConn = getConn();
try (OracleCallableStatement vOCS = (OracleCallableStatement) vConn.prepareCall(getStmt(EXPORT_APPLICATION))) {
vOCS.registerOutParameter(1, 2005);
vOCS.setBigDecimal(2, getApplicationId());
if (getApexVersion() >= APEX_VERSION_4) {
vOCS.setString(3, isExpPubReports() ? "Y" : "N");
vOCS.setString(4, isExpSavedReports() ? "Y" : "N");
vOCS.setString(5, isExpIRNotifications() ? "Y" : "N");
vOCS.setString(6, isExpTranslations() ? "Y" : "N");
}
if (getApexVersion() >= APEX_VERSION_5) {
vOCS.setString(7, isExpAppMapping() ? "Y" : "N");
vOCS.setString(8, isExpOriginalIds() ? "Y" : "N");
}
vOCS.execute();
vClob = vOCS.getCLOB(1);
}
return vClob;
}
开发者ID:FwMontadorVersaoDevTeam,项目名称:ApexExporter,代码行数:32,代码来源:Exporter.java
示例3: getFeedback
import oracle.sql.CLOB; //导入依赖的package包/类
/**
* Método getFeedback
*
* @since APEX 4
* @return oralce.sql.CLOB
* @throws java.sql.SQLException
* @throws java.io.IOException
*/
private CLOB getFeedback() throws SQLException, IOException {
CLOB vClob;
Connection vConn = getConn();
try (OracleCallableStatement vOCS = (OracleCallableStatement) vConn.prepareCall(getStmt(getDeploymentSystem() == null ? EXPORT_FEEDBACK_DEVELOPMENT : EXPORT_FEEDBACK_DEPLOYMENT))) {
vOCS.registerOutParameter(1, 2005);
vOCS.setBigDecimal(2, getWorkspaceId());
if (getDeploymentSystem() == null) {
vOCS.setDate(3, getExpFeedbackSince());
} else {
vOCS.setString(3, getDeploymentSystem());
vOCS.setDate(4, getExpFeedbackSince());
}
vOCS.execute();
vClob = vOCS.getCLOB(1);
}
return vClob;
}
开发者ID:FwMontadorVersaoDevTeam,项目名称:ApexExporter,代码行数:26,代码来源:Exporter.java
示例4: get
import oracle.sql.CLOB; //导入依赖的package包/类
/**
* Método de expotação
*
* @since APEX 3 Parcial
* @since APEX 4 Parcial
* @since APEX 5
* @return oracle.sql.CLOB
* @throws java.sql.SQLException
* @throws java.io.IOException
*/
public CLOB get() throws SQLException, IOException {
CLOB vClob = null;
iniciarStmts();
if (isExpWorkspace()) {
if (getApexVersion() >= APEX_VERSION_4) {
vClob = getWorkspace();
}
} else if (isExpFeedback()) {
if (getApexVersion() >= APEX_VERSION_4) {
vClob = getFeedback();
}
} else if (isExpFiles()) {
if (getApexVersion() >= APEX_VERSION_4) {
vClob = getStaticFiles();
}
} else {
vClob = getFile();
}
if (!isExternalConn()) {
closeConnection();
}
return vClob;
}
开发者ID:FwMontadorVersaoDevTeam,项目名称:ApexExporter,代码行数:34,代码来源:Exporter.java
示例5: getTemporaryClob
import oracle.sql.CLOB; //导入依赖的package包/类
public final CLOB getTemporaryClob() {
checkOpen();
CLOB lCLOB;
try {
lCLOB = CLOB.createTemporary(
mDatabaseConnection.unwrap(OracleConnection.class)
, true /*isCached*/
, CLOB.DURATION_SESSION /* Only duration_session in client side java applications */
);
}
catch (SQLException e) {
throw new ExInternal("Temporary clob cannot be created", e);
}
return lCLOB;
}
开发者ID:Fivium,项目名称:FOXopen,代码行数:17,代码来源:UCon.java
示例6: pumpMessages
import oracle.sql.CLOB; //导入依赖的package包/类
@Test
public void pumpMessages() throws Exception {
java.util.logging.LogManager.getLogManager().getLogger("").setLevel(Level.FINEST);
SLF4JBridgeHandler.removeHandlersForRootLogger();
SLF4JBridgeHandler.install();
log.info("Creating UNIT TEST Class");
createOracleAQQueue();
Clob message = CLOB.createTemporary(dbConnection, false, CLOB.DURATION_SESSION);
message.setString(1, TEST_MESSAGE);
String plsql = String.format("begin mdb_aq.send_message('" + DB_SCHEMA_NAME + ".%1$s', ?); end;", oracleQueueName);
CallableStatement statement = dbConnection.prepareCall(plsql);
statement.setClob(1, message);
statement.execute();
statement.close();
message.free();
}
开发者ID:yashpatil,项目名称:aq-to-amq,代码行数:21,代码来源:PumpMessagesIntoOracleAQTest.java
示例7: setUp
import oracle.sql.CLOB; //导入依赖的package包/类
@Before
public void setUp() throws SQLException, IOException, MjdbcException {
MockitoAnnotations.initMocks(this);
when(stmt.getConnection()).thenReturn(conn);
when(conn.createARRAY(any(String.class), any(Object[].class))).thenReturn(array);
when(blob.setBinaryStream(1)).thenReturn(output);
when(clob.setAsciiStream(1)).thenReturn(output);
when(input.read(any(byte[].class))).thenReturn(-1);
when(input.read(any(byte[].class), any(int.class), any(int.class))).thenReturn(-1);
when(blob.getBinaryStream()).thenReturn(input);
when(clob.getAsciiStream()).thenReturn(input);
params = new QueryParameters();
params.set("array_list", Arrays.asList("Superman"), MjdbcTypes.ARRAY);
params.set("blob_byte", "Batman", MjdbcTypes.BLOB);
params.set("clob_byte", "Wolverine", MjdbcTypes.CLOB);
params.set("array", array, MjdbcTypes.ARRAY);
params.set("blob", blob, MjdbcTypes.BLOB);
params.set("clob", clob, MjdbcTypes.CLOB);
}
开发者ID:pryzach,项目名称:midao,代码行数:27,代码来源:OracleTypeHandlerTest.java
示例8: testGetCount
import oracle.sql.CLOB; //导入依赖的package包/类
@Test
public void testGetCount() throws Exception {
QueryStatCtl ctl=(QueryStatCtl) ApplicationContextUtil.getBean("QueryStatCtl");
StringBuilder sb=new StringBuilder();
sb.append("clob:");
for (int i=0;i<300;i++){
sb.append("1");
}
Map<String,Object> obj=(Map<String,Object>)ctl.testPro("testPro",
"dataType配置为varchar",
100,
"2010-08-22",
new Date(),sb.toString(),"blob:hello".getBytes());
System.out.println(obj.get("p_info")+"\n");
CLOB demo = (CLOB)obj.get("p_outclob");
System.out.println(demo.getSubString(1, (int) demo.length()) +"\n");
BLOB blob = (BLOB)obj.get("p_outblob");
System.out.println(new String(blob.getBytes(1,(int)blob.length()),"UTF-8")+"\n");
Object result=obj.get("p_cursor");
if(result instanceof String){
log.info(obj.get("p_cursor").toString());
}else{
for (Person person:(List<Person>)result){
log.info(person.getName()+" "+person.getSchool()+" "+person.getAge().toLocaleString()+" "+person.getId());
}
}
}
开发者ID:DistX,项目名称:Learning,代码行数:35,代码来源:AppTest.java
示例9: getWorkspace
import oracle.sql.CLOB; //导入依赖的package包/类
/**
* Método responsável pela extração de espaços de trabalho
*
* @since APEX 4
* @return Espaço de trabalho
* @throws java.sql.SQLException
* @throws java.io.IOException
*/
private CLOB getWorkspace() throws SQLException, IOException {
CLOB vClob;
Connection vConn = getConn();
try (OracleCallableStatement vOCS = (OracleCallableStatement) vConn.prepareCall(getStmt(EXPORT_WORKSPACE))) {
vOCS.registerOutParameter(1, 2005);
vOCS.setBigDecimal(2, getWorkspaceId());
vOCS.setBoolean(3, isExpTeamdevdata());
vOCS.setBoolean(4, isExpTeamdevdata() ? isExpMinimal() : false);
vOCS.execute();
vClob = vOCS.getCLOB(1);
}
return vClob;
}
开发者ID:FwMontadorVersaoDevTeam,项目名称:ApexExporter,代码行数:22,代码来源:Exporter.java
示例10: getStaticFiles
import oracle.sql.CLOB; //导入依赖的package包/类
/**
* Método responsável pela exportação de arquivos estáticos
*
* @since APEX 4
* @return Arquivos estáticos
* @throws java.sql.SQLException
* @throws java.io.IOException
*/
private CLOB getStaticFiles() throws SQLException, IOException {
CLOB vClob;
Connection vConn = getConn();
try (OracleCallableStatement vOCS = (OracleCallableStatement) vConn.prepareCall(getStmt(EXPORT_STATIC_FILES))) {
vOCS.registerOutParameter(1, 2005);
vOCS.setBigDecimal(2, getWorkspaceId());
vOCS.execute();
vClob = vOCS.getCLOB(1);
}
return vClob;
}
开发者ID:FwMontadorVersaoDevTeam,项目名称:ApexExporter,代码行数:20,代码来源:Exporter.java
示例11: writeClobToFile
import oracle.sql.CLOB; //导入依赖的package包/类
/**
* Gera arquivo em disco
*
* @param pClob
* @param pFileName
* @throws java.sql.SQLException
* @throws java.io.IOException
*/
private void writeClobToFile(CLOB pClob, String pFileName) throws SQLException, IOException {
CLOB vClob = pClob;
boolean vCtrl = true;
FileOutputStream vFOS;
OutputStreamWriter vOSW;
try (Reader vReader = vClob.getCharacterStream()) {
File vFile = new File(getPath() + pFileName);
vFile.delete();
vFile.createNewFile();
vFOS = new FileOutputStream(vFile);
vOSW = new OutputStreamWriter(vFOS, "UTF-8");
BufferedReader vBR = new BufferedReader(vReader);
String vLine;
while ((vLine = vBR.readLine()) != null) {
vLine = vLine + "\n";
if (vCtrl) {
if (vLine.indexOf("set define") != 0) {
continue;
}
vCtrl = false;
vOSW.write(vLine, 0, vLine.length());
continue;
}
if (isSkipExportDate() && vLine.indexOf("-- Date and Time:") == 0) {
continue;
}
vOSW.write(vLine, 0, vLine.length());
}
vOSW.flush();
debugMessage("Wrote " + vFile.length() + " bytes to " + vFile.getAbsolutePath(), true);
}
vOSW.close();
vFOS.close();
}
开发者ID:FwMontadorVersaoDevTeam,项目名称:ApexExporter,代码行数:43,代码来源:Exporter.java
示例12: convertClobToSQLXML
import oracle.sql.CLOB; //导入依赖的package包/类
public SQLXML convertClobToSQLXML(Clob pClob) {
//TODO make database agnostic
try {
return XMLType.createXML(mDatabaseConnection.unwrap(OracleConnection.class), (CLOB) pClob);
}
catch(SQLException e) {
throw new ExInternal("XMLType can not be created",e);
}
}
开发者ID:Fivium,项目名称:FOXopen,代码行数:10,代码来源:UCon.java
示例13: freeTemporaryClob
import oracle.sql.CLOB; //导入依赖的package包/类
/**
* Frees a temporary CLOB. If the CLOB is not temporary, this method does nothing.
* @param pTempClob CLOB to be freed.
*/
public final void freeTemporaryClob(CLOB pTempClob) {
checkOpen();
try {
if(pTempClob!=null && pTempClob.isTemporary()) {
pTempClob.freeTemporary();
}
}
catch (SQLException e) {
throw new ExInternal("Temporary clob cannot be freed", e);
}
}
开发者ID:Fivium,项目名称:FOXopen,代码行数:16,代码来源:UCon.java
示例14: getObject
import oracle.sql.CLOB; //导入依赖的package包/类
@Override
public Object getObject(UCon pUCon) throws SQLException {
//As this is an XML fragment there is no direct way to bind it using the JDBC APIs, which all expect a SQLXML
//object to be a valid XML document. Workaround is to use the Oracle EXTRACT function on a wrapped version of the
//fragment, to create a SQLXML object which represents the fragment.
CLOB lClob = pUCon.getTemporaryClob();
try {
Writer lClobWriter = lClob.setCharacterStream(0);
//Add a parent "root" node to wrap the fragment
lClobWriter.write("<root>" + mSelectedNodes.outputNodesToString() + "</root>");
lClobWriter.close();
}
catch (IOException | SQLException e) {
throw new ExInternal("Error Writing to temporary clob for xmltype fragment", e);
}
// send the clob to the dataase and extact the xml root
PreparedStatement lExtractStatement = pUCon.getJDBCConnection().prepareStatement(CLOB_TO_XML_FRAGMENT_CONVERSION_SQL);
lExtractStatement.setClob(1, lClob);
//Execute the query and increment the result set
mFragmentResultSet = lExtractStatement.executeQuery();
mFragmentResultSet.next();
//Now the object returned should be an xml fragment
mSQLXML = mFragmentResultSet.getSQLXML(1);
lClob.freeTemporary();
lExtractStatement.close();
return mSQLXML;
}
开发者ID:Fivium,项目名称:FOXopen,代码行数:35,代码来源:DOMListBindObject.java
示例15: getLOBForBinding
import oracle.sql.CLOB; //导入依赖的package包/类
@Override
public Object getLOBForBinding(UCon pUCon, BindSQLType pBindTypeRequired, DOM pDOM) {
if(pBindTypeRequired == BindSQLType.CLOB) {
return mFetchedCLOB;
}
else if (pBindTypeRequired == BindSQLType.XML) {
return pUCon.convertClobToSQLXML(mFetchedCLOB);
}
else {
throw new ExInternal("Don't know how to bind XML LOB as a " + pBindTypeRequired + ")");
}
}
开发者ID:Fivium,项目名称:FOXopen,代码行数:13,代码来源:ClobDOMAccessor.java
示例16: clobToString
import oracle.sql.CLOB; //导入依赖的package包/类
public String clobToString(CLOB clob) throws SQLException, IOException {
Reader is = clob.getCharacterStream();// 得到流
BufferedReader br = new BufferedReader(is);
String s = br.readLine();
StringBuffer buff = new StringBuffer();
while (s != null) {// 执行循环将字符串全部取出付值给StringBuffer由StringBuffer转成STRING
buff.append(s);
s = br.readLine();
}
br.close();
return buff.toString();
}
开发者ID:HuQingmiao,项目名称:easydb,代码行数:14,代码来源:OracleRsAssembler.java
示例17: doUpdate
import oracle.sql.CLOB; //导入依赖的package包/类
public int doUpdate(SBulletin bul) throws Exception{
String sql = "update s_bulletin " +
" set BULLETIN_TITLE = ?, " +
// " CREATE_DATE = ?, " +
" BULLETIN_CONTENT= ?, " +
// " BULLETIN_PUBLISHER= ?, " +
// " STATUS= ?, " +
// " OPTR_ID= ?, " +
" EFF_DATE= ?, " +
" EXP_DATE= ? " +
" where bulletin_id = ?";
Connection conn = this.getConnection();
PreparedStatement pst = null;
int result = 0;
try{
pst = conn.prepareStatement(sql);
pst.setString(1, bul.getBulletin_title());//BULLETIN_TITLE
C3P0NativeJdbcExtractor cp30NativeJdbcExtractor = new C3P0NativeJdbcExtractor();
OracleConnection oracleConn = (OracleConnection) cp30NativeJdbcExtractor.getNativeConnection(pst.getConnection());
CLOB clob = oracle.sql.CLOB.createTemporary(oracleConn, false, oracle.sql.CLOB.DURATION_SESSION);
clob.putString(1,bul.getBulletin_content());
pst.setClob(2, clob);//BULLETIN_CONTENT
pst.setDate(3, new java.sql.Date(bul.getEff_date().getTime()));//EFF_DATE
pst.setDate(4, new java.sql.Date(bul.getExp_date().getTime()));//EXP_DATE
pst.setString(5, bul.getBulletin_id());
result = pst.executeUpdate();
}catch (SQLException ex) {
JdbcUtils.closeStatement(pst);
pst = null;
DataSourceUtils.releaseConnection(conn, getDataSource());
conn = null;
throw ex;
}finally {
JdbcUtils.closeStatement(pst);
DataSourceUtils.releaseConnection(conn, getDataSource());
}
return result;
}
开发者ID:leopardoooo,项目名称:cambodia,代码行数:40,代码来源:SBulletinDao.java
示例18: doSave
import oracle.sql.CLOB; //导入依赖的package包/类
public int doSave(SBulletin bulletin) throws Exception{
// SEQ_S_BULLETIN.Nextval,bulletin_content,create_date,bulletin_title,
// status,exp_date,optr_id,bulletin_publisher,bulletin_id,eff_date
String sql = "INSERT INTO S_BULLETIN (bulletin_id,bulletin_content,create_date,bulletin_title," +
"status,exp_date,optr_id,bulletin_publisher,eff_date) " +
"values (?,?,sysdate,?,?,?,?,?,?)";
Connection conn = this.getConnection();
PreparedStatement pst = null;
int result = 0;
try{
pst = conn.prepareStatement(sql);
C3P0NativeJdbcExtractor cp30NativeJdbcExtractor = new C3P0NativeJdbcExtractor();
OracleConnection oracleConn = (OracleConnection) cp30NativeJdbcExtractor.getNativeConnection(pst.getConnection());
pst.setString(1, bulletin.getBulletin_id());
CLOB clob = oracle.sql.CLOB.createTemporary(oracleConn, false, oracle.sql.CLOB.DURATION_SESSION);
clob.putString(1,bulletin.getBulletin_content());
pst.setClob(2, clob);//bulletin_content
pst.setString(3, bulletin.getBulletin_title());//bulletin_title
pst.setString(4, bulletin.getStatus());//status
pst.setDate(5, new java.sql.Date(bulletin.getExp_date().getTime()));//exp_date
pst.setString(6, bulletin.getOptr_id());//optr_id
pst.setString(7, bulletin.getBulletin_publisher());//bulletin_publisher
pst.setDate(8, new java.sql.Date(bulletin.getEff_date().getTime()));//eff_date
result = pst.executeUpdate();
}catch (SQLException ex) {
JdbcUtils.closeStatement(pst);
pst = null;
DataSourceUtils.releaseConnection(conn, getDataSource());
conn = null;
throw ex;
}finally {
JdbcUtils.closeStatement(pst);
DataSourceUtils.releaseConnection(conn, getDataSource());
}
return result;
}
开发者ID:leopardoooo,项目名称:cambodia,代码行数:37,代码来源:SBulletinDao.java
示例19: setUp
import oracle.sql.CLOB; //导入依赖的package包/类
@Before
public void setUp() throws SQLException, IOException, MjdbcException {
MockitoAnnotations.initMocks(this);
when(stmt.getConnection()).thenReturn(conn);
when(conn.createARRAY(any(String.class), any(Object[].class))).thenReturn(array);
when(MappingUtils.invokeFunction(conn, "createBlob", new Class[]{}, new Object[]{})).thenReturn(blob);
when(MappingUtils.invokeFunction(conn, "createClob", new Class[]{}, new Object[]{})).thenReturn(clob);
when(blob.setBinaryStream(1)).thenReturn(output);
when(clob.setAsciiStream(1)).thenReturn(output);
when(input.read(any(byte[].class))).thenReturn(-1);
when(input.read(any(byte[].class), any(int.class), any(int.class))).thenReturn(-1);
when(blob.getBinaryStream()).thenReturn(input);
when(clob.getAsciiStream()).thenReturn(input);
params = new QueryParameters();
params.set("array_list", Arrays.asList("Superman"), MjdbcTypes.ARRAY);
params.set("blob_byte", "Batman", MjdbcTypes.BLOB);
params.set("clob_byte", "Wolverine", MjdbcTypes.CLOB);
params.set("array", array, MjdbcTypes.ARRAY);
params.set("blob", blob, MjdbcTypes.BLOB);
params.set("clob", clob, MjdbcTypes.CLOB);
}
开发者ID:pryzach,项目名称:midao,代码行数:29,代码来源:OracleTypeHandlerTest.java
示例20: getCLOB
import oracle.sql.CLOB; //导入依赖的package包/类
@Override
public CLOB getCLOB(int paramInt) throws SQLException {
return oracleRs.getCLOB(paramInt);
}
开发者ID:dd00f,项目名称:ibm-performance-monitor,代码行数:5,代码来源:WrappedOracleResultSet.java
注:本文中的oracle.sql.CLOB类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论