Java向Oracle数据库表中插入CLOB、BLOB字段

2024-08-22 09:18

本文主要是介绍Java向Oracle数据库表中插入CLOB、BLOB字段,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在需要存储较长字符串到数据库中时往往需要使用一些特殊类型的字段,在Oracle中即blob和clob字段,一般而言:Clob字段存储字符信息,比如较长的文字、评论,Blob字段存储字节信息,比如图像的base64编码。

注意,上述字段的使用均可以用其他方式替代,比如用MongoDB或者图片直接存储为文件等等,这里不纠结场景的合适与否,只是针对Blob和Clob类型的使用来举例。

操作场景

主要有三种场景:

  • 仅对已知表中的某一字段写入Blob和Clob字段的值
  • 更新已知表中全部字段的值(均为Blob和Clob字段)
  • 插入数据中带有部分需要插入Blob和Clob字段的数据

总结来看,后两种均以第一种场景为基础,即我们必须明确如何向Blob和Clob字段写入数据。第二种场景实际上是第一种的重复操作,那么对于第三种,需要十分注意,这里意味着需要向表中插入一行记录,操作有部分差异,在此我们就用第三种场景为例来给出示例。

插入时带Blob和Clob字段

情景再现:

从数据源接收数据,解析完成后产生SQL语句并批量插入数据表,注意,原记录中含有若干个Blob字段(图片编码)和若干个Clob字段(记录信息),其余字段均为一般类型(String,Integer)

在给出代码前,注意几点:

  1. Blob和Clob需要单独处理,即一个SQL语句无法完成上述需求
  2. 整个过程分为三部分:组装SQL语句、第一遍插入、第二次插入Blob和Clob类型
  3. 组装SQL语句时:Blob需要人为empty_blob(),置空为Clob需要人为置空为empty_clob()
  4. 每次插入都需要对特殊字段进行处理,故无法使用batch操作
  5. 特殊字段处理(第二次插入),必须在第一遍插入之后进行,此时已初始化为empty_blob()或empty_clob()

下面就以带特定场景需求的代码来展示写入示例。

代码背景

数据源每次发送一个XML字符串非常长,代码端每次解析这个串,解析后会成为 N 条记录,其中每条记录要解析为 M 个字段,其中含有 m 个Blob字段和 n 个Clob字段,现在需要把这 N 条记录插入到数据表中。

上述的 N,M,n,m 大小均不定且动态变化(已知某些字段是,但这些字段不一定出现),即大小未知。

大致代码流程

// ... ... 整个过程围绕xml节点的迭代来完成

while(iter1.hasNext()){

Element e = iter1.next();
Iterator<Element> iter2 = e.elementIterator();

// 每一条SQL
while(iter2.hasNext()){

boolean flag1 = false; // 标志是否含有Clob字段
boolean flag2 = false; // 标志是否含有Blob字段

String blobId = ""; // 储存所在SQL语句的主键值

// ... ...

// 开始组装每一条SQL语句
Iterator<Element> iter3 = f.elementIterator();
while(iter3.hasNext()){

// ... ...

switch(colname){

case "CLOB字段名1" :
case "CLOB字段名2" :
// ...
case "CLOB字段名N" : { //暂存CLOB数据
cList.add(colname);
cList.add(h.getStringValue());
flag1 = true;
break; // break switch
}
case "BLOB字段名1" :
case "BLOB字段名2" :
// ...
case "BLOB字段名N" :{ //暂存BLOB数据
bList.add(colname);
bList.add(h.getStringValue());
flag2 = true;
break;
}
default:{
if( this value is the primary key ){
blobId = this value
}

strVALUE.append( this valu , ); // 字段值
strNAMES.append( his value , ); // 字段名
}
}
}
// 去掉最后一个多余的逗号
strVALUE.deleteCharAt( strVALUE.length() - 1);
strNAMES.deleteCharAt( strNAMES.length() - 1);

// 然后追加处理 empty_clob()和empty_blob()

for(int i = 0;i < cList.size(); i=i+2){
strNAMES.append(",\""+cList.get(i)+"\"");
strVALUE.append(",empty_clob()");
}
for(int i = 0;i < bList.size(); i=i+2){
strNAMES.append(",\""+bList.get(i)+"\"");
strVALUE.append(",empty_blob()");
}

// 最终形态(第一次插入的语句)
sqlStr.append("INSERT INTO 表名 ( "+strNAMES+" ) VALUES ( "+strVALUE+" )");

pstmt = con.prepareStatement(sqlStr.toString());

pstmt.executeUpdate(); // first insert done

if(pstmt != null){
pstmt.close();
}

// 上述第一次插入完成后,开始单独处理特殊类型(第二次插入)

// 根据 flag1 判断是否有Clob类型的数据
if(flag1){
for(int i = 0;i < cList.size(); i=i+2){
pstmt = con.prepareStatement(
"SELECT "+cList.get(i)+" FROM 表名 WHERE 表主键 = "+blobId+" for update");
ResultSet rs = pstmt.executeQuery();
Writer outStream = null;
if (rs.next()) {
//得到java.sql.Clob对象后强制转换为oracle.sql.CLOB
oracle.sql.CLOB clob = (oracle.sql.CLOB) rs.getClob(cList.get(i));
outStream = clob.getCharacterOutputStream();
//传入字符串
char[] c = cList.get(i+1).toCharArray();
outStream.write(c, 0, c.length);
}
outStream.flush();
outStream.close();
con.commit();
if(pstmt != null){
pstmt.close();
}
}
}

// 根据 flag1 判断是否有Blob类型的数据
if(flag2){
for(int i = 0;i < bList.size(); i=i+2){
pstmt = con.prepareStatement(
"SELECT "+bList.get(i)+" FROM 表名 WHERE 表主键 = "+blobId+" for update" );
ResultSet rs = pstmt.executeQuery();
OutputStream os = null;
if (rs.next()) {
// 得到java.sql.Blob对象后强制转换为oracle.sql.BLOB
oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob(bList.get(i));
// 通过getBinaryOutputStream()方法获得向数据库中插入图片的流
os = blob.getBinaryOutputStream();
// 读取想要存储的图片文件(或串值)
InputStream is = new ByteArrayInputStream(bList.get(i+1).getBytes());
// 依次读取流字节,并输出到已定义好的数据库字段中.
int b = 0;
while ((b = is.read()) != -1) {
os.write(b);
}
}
os.flush();
os.close();
con.commit();
if(pstmt != null){
pstmt.close();
}
}
}
} // end while
} // end while

上述代码段的环境非常特殊,前面已经说了,是一个比较复杂的处理逻辑,代码中有些变量定义没写出来,有些地方也去掉了特定变量换成了文字叙述,所以,上述代码仅仅是为了提供思路,并且包含了一些处理技巧:

  • 如何结合XML对象解析构造SQL
  • 如何拼接SQL字符串
  • 如何暂存特殊类型字段
  • 如何在第一次插入时设置empty_blob()
  • 如何通过主键值来进行第二次插入
  • 如何插入Blob和Clob字段

如果你有更好的方法或者是对该文章有任何的疑问或想法,请在下方留言,我会第一时间回复的!



😒 留下您对该文章的评价 😄


这篇关于Java向Oracle数据库表中插入CLOB、BLOB字段的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1095860

相关文章

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时,有没有考虑过 JVM 是如何把静态的字节码(byte code)转化为运行时对象的呢,这个问题看似简单,但清楚的同学相信也不会太多,这篇文章首先介绍 JVM 类初始化的机制,然后给出几个易出错的实例来分析,帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段,分别是:loading 、Linking、initialization

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权,允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true (Spring security默认会带有ROLE_前缀),去

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程,特意画了如下的类图,包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口,接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类,它们之间的依赖,构建起了整个框架。想要理解整个架构,最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文(security context)的信息。当前操作的用户是谁,该用户是否已经被认证,他拥有哪些角色权限…这些都被保

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明(认真看哦) AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证,则会调用 #attemptAuthentica

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门(一):登录与退出》 《Spring-Security-入门(二):基于数据库验证》 《Spring-Security-入门(三):密码加密》 《Spring-Security-入门(四):自定义-Filter》 《Spring-Security-入门(五):在 Sprin

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物

Java进阶13讲__第12讲_1/2

多线程、线程池 1.  线程概念 1.1  什么是线程 1.2  线程的好处 2.   创建线程的三种方式 注意事项 2.1  继承Thread类 2.1.1 认识  2.1.2  编码实现  package cn.hdc.oop10.Thread;import org.slf4j.Logger;import org.slf4j.LoggerFactory

MySQL数据库宕机,启动不起来,教你一招搞定!

作者介绍:老苏,10余年DBA工作运维经验,擅长Oracle、MySQL、PG、Mongodb数据库运维(如安装迁移,性能优化、故障应急处理等)公众号:老苏畅谈运维欢迎关注本人公众号,更多精彩与您分享。 MySQL数据库宕机,数据页损坏问题,启动不起来,该如何排查和解决,本文将为你说明具体的排查过程。 查看MySQL error日志 查看 MySQL error日志,排查哪个表(表空间

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来,一站式有声阅读平台听书系统 🌟&nbsp;开篇:遇见未来,从“智听”开始 在这个快节奏的时代,你是否渴望在忙碌的间隙,找到一片属于自己的宁静角落?是否梦想着能随时随地,沉浸在知识的海洋,或是故事的奇幻世界里?今天,就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统,它正悄悄改变着我们的阅读方式,让未来触手可及! 📚&nbsp;第一站:海量资源,应有尽有 走进“智听