java 大字符串转为二进制流存入CLOB字段 JDBC方法

我以前写程序发现：

oracle的数据库BLOB不能用来存储字符，改用NCLOB就OK了。

BLOB：用来存储无结构的二进制数据

CLOB：存储单字节字符数据。（别用来存中文喔。。。）

NCLOB：用来存储定宽多字节字符数据。

1、MyBatis介绍

MyBatis 本是apache的一个开源项目iBatis, 2010年这个项目由apache software foundation 迁移到了google code，并且改名为MyBatis 。2013年11月迁移到Github。

iBATIS一词来源于“internet”和“abatis”的组合，是一个基于Java的持久层框架。iBATIS提供的持久层框架包括SQL Maps和Data Access Objects（DAO）

2、CLOB

SQL CLOB 是内置类型，它将字符大对象 (Character Large Object) 存储为数据库表某一行中的一个列值。默认情况下，驱动程序使用 SQL locator(CLOB) 实现 Clob 对象，这意味着 CLOB 对象包含一个指向 SQL CLOB 数据的逻辑指针而不是数据本身。Clob 对象在它被创建的事务处理期间有效。

3、MyBatis对CLOB类型数据实现增删改查

oracle表结构

create table T_USERS  

(  

  ID      NUMBER not null,  

  NAME    VARCHAR2(30),  

  SEX     VARCHAR2(3),  

  BIRS    DATE,  

  MESSAGE CLOB  

)  

create sequence SEQ_T_USERS_ID  

minvalue 1  

maxvalue 99999999  

start with 1  

increment by 1  

cache 20;

配置mybatis配置文件UsersMapperxml

<xml version="10" encoding="UTF-8">

<!DOCTYPE mapper

  PUBLIC "-//mybatisorg//DTD Mapper 30//EN">

<mapper namespace="examplesmapperUsersMapper" >

<!-- Result Map-->

<resultMap type="examplesbeanUsers" id="BaseResultMap">

<result property="id" column="id" />

<result property="name" column="name" />

<result property="sex" column="sex" />

<result property="birs" column="birs" jdbcType="TIMESTAMP"/>

<result property="message" column="message" jdbcType="CLOB" 

javaType = "javalangString"  typeHandler ="examplesserviceOracleClobTypeHandler"/>

</resultMap>

<sql id="Tabel_Name">

t_users

</sql>

<!-- 表中所有列 -->

<sql id="Base_Column_List" >

id,name,sex,birs,message

</sql>

<!-- 查询条件 -->

<sql id="Example_Where_Clause">

where 1=1

<trim suffixOverrides=",">

<if test="id != null">

and id = #{id}

</if>

<if test="name != null and name != ''">

and name like concat(concat('%', '${name}'), '%')

</if>

<if test="sex != null and sex != ''">

and sex like concat(concat('%', '${sex}'), '%')

</if>

<if test="birs != null">

and birs = #{birs}

</if>

<if test="message != null">

and message = #{message}

</if>

</trim>

</sql>

<!-- 2查询列表 -->

<select id="queryByList" resultMap="BaseResultMap" parameterType="Object">

select

<include refid="Base_Column_List" />

from t_users 

<include refid="Example_Where_Clause"/>

</select>

</mapper>

Mapper类接口

package examplesmapper;

import javautilList;

public interface UsersMapper<T> {

public List<T> queryBySelective(T t);

public List<T> queryByList(T t);

}

类型转换工具类

package examplesservice;

import javasqlCallableStatement;

import javasqlPreparedStatement;

import javasqlResultSet;

import javasqlSQLException;

import oraclesqlCLOB;

import orgapacheibatistypeJdbcType;

import orgapacheibatistypeTypeHandler;

public class OracleClobTypeHandler implements TypeHandler<Object> {

public Object valueOf(String param) {

return null;

}

@Override

public Object getResult(ResultSet arg0, String arg1) throws SQLException {

CLOB clob = (CLOB) arg0getClob(arg1);

return (clob == null || cloblength() == 0)  null : clobgetSubString((long) 1, (int) cloblength());

}

@Override

public Object getResult(ResultSet arg0, int arg1) throws SQLException {

return null;

}

@Override

public Object getResult(CallableStatement arg0, int arg1) throws SQLException {

return null;

}

@Override

public void setParameter(PreparedStatement arg0, int arg1, Object arg2, JdbcType arg3) throws SQLException {

CLOB clob = CLOBempty_lob();

clobsetString(1, (String) arg2);

arg0setClob(arg1, clob);

}

}

Spring配置文件

<xml version="10" encoding="UTF-8">

<beans xmlns="

xmlns:xsi="

xmlns:mvc="

xmlns:tx="

xsi:schemaLocation="

default-autowire="byType">

<!-- 配置数据源 -->

<bean id="dataSource" class="orgspringframeworkjdbcdatasourceDriverManagerDataSource">

         <property name="driverClassName"><value>oraclejdbcdriverOracleDriver</value></property> 

         <property name="url"><value>jdbc:oracle:thin:@127001:1521:pms</value></property> 

         <property name="username"><value>pms</value></property> 

         <property name="password"><value>pms</value></property>

</bean>

<!-- 配完数据源 和 拥有的 sql映射文件 sqlSessionFactory 也可以访问数据库 和拥有 sql *** 作能力了 -->

<!-- 

<bean id="sqlSessionFactory" class="orgmybatisspringSqlSessionFactoryBean">

<property name="dataSource" ref="dataSource" />

   <property name="configLocation" value="classpath:mybatis-configxml"/>

</bean>

 -->

<bean id="sqlSessionFactory" class="orgmybatisspringSqlSessionFactoryBean">

<property name="dataSource" ref="dataSource" />

<property name="mapperLocations">

<list>

<value>classpath:examples/mybatis/oracle/UsersMapperxml</value>

</list>

</property>

</bean>

<!-- 通过设置 mapperInterface属性，使接口服务bean 和对应xml文件管理 可以使用其中的sql -->

<bean id="dao" class="orgmybatisspringmapperMapperFactoryBean">

<!-- 此处等同于 Mybatis 中 ServerDao serverDao = sqlSessiongetMapper(ServerDaoclass); 指明映射关系 -->

<property name="mapperInterface" value="examplesmapperUsersMapper" />

<property name="sqlSessionFactory" ref="sqlSessionFactory" />

</bean>

</beans>

测试类

package examplesservice;

import javatextParseException;

import javatextSimpleDateFormat;

import javautilList;

import orgspringframeworkcontextApplicationContext;

import orgspringframeworkcontextsupportClassPathXmlApplicationContext;

import examplesbeanUsers;

import examplesmapperUsersMapper;

public class TestUsersService {

@SuppressWarnings("unchecked")

public static void main(String[] args) throws ParseException {

ApplicationContext ac = 

new ClassPathXmlApplicationContext("classpath:/examples/service/springxml");

UsersMapper<Users> dao = (UsersMapper<Users>)acgetBean("dao");

//查询

 Users nullBean = new Users();

List<Users> list = daoqueryByList(nullBean);

if(list != null) {

for(Users user : list) {

Systemoutprintln(user);

}

}

}

}

1：首先：写个连接数据库的类，里面有返回mysq， oracle连接的方法

public Connection getConn(String flag){

Connection con=null;

try

{

if(flagequals("1"))

{

ClassforName(“oraclejdbcdriverOracleDriver”);

con = DriverManagergetConnection(“jdbc:oracle:thin:@IP:1521:数据库名字”,"name","password");

}

if(flagequals("2"))

{

ClassforName("orggjtmmmysqlDriver");

con = DriverManagergetConnection("jdbc:mysql://localhost/数据库名user=用户名&password=密码&useUnicode=true&characterEncoding=GBK");

}

}

catch(Exception e)

{

eprintStackTrace();

}

return con;

}

2:执行插入 *** 作

public void setData() {

conn = new Conn();

try {

String sqlfrom = "select pid,pcontent from table p order by pid ";

String sqlinsert = "insert into table values(,)";

con = conngetConn("2");

stmt = concreateStatement(); //从mysql取出大字段

rs = stmtexecuteQuery(sqlfrom);

con = conngetConn("1");

PreparedStatement pstmt = conprepareStatement(sqlinsert); //向oracle中插入大字段

int i = 0;

while (rsnext()) {

pstmtsetInt(1, rsgetInt(1));

pstmtsetClob(2, oraclesqlCLOBempty_lob());

pstmtexecuteUpdate(); //插入时将大字段设为空

thisupdateOne(con,rsgetInt(1),rsgetString(2)); // 这里调用然后更新这个大字段

}

rsclose(); //关闭相关连接

pstmtclose();

stmtclose();

conclose();

} catch (Exception e) {

eprintStackTrace();

try

{

conrollback();

} catch (Exception e1) {

Systemoutprintln("回滚出现异常！");

e1printStackTrace();

}

}

}

3:该方法实现对应大字段记录的更新

public void updateOne(Connection con,int id, String content) {

String str = "select tcontent from table t where tid=" + id+ " for update";

try {

// 注意：存取 *** 作开始前，必须用setAutoCommit(false)取消自动提交，否则Oracle将抛出“读取违反顺序”的错误。

consetAutoCommit(false);

stmt = concreateStatement();

ResultSet rs_clob = stmtexecuteQuery(str);

while ( rs_clob next()) {

/ 取出clob数据/

oraclesqlCLOB clob = (oraclesqlCLOB) rs_clob getClob(1);

/ 向clob中写入数据/

clobputString(1, content);

}

stmtclose();

concommit();

consetAutoCommit(true);

conclose();

} catch (Exception e) {

eprintStackTrace();

try

{

conrollback();

} catch (Exception e1) {

Systemoutprintln("回滚出现异常！");

e1printStackTrace();

}

}

}

现在就完成了一行记录的更新。

4：读clob字段以String 的形式返回（当然也可以将读到的内容写入文件，大家改一下就可以了）

/

读clob字段

@param con

@param id

@return

/

public String readClob(Connection con,int id)

{

String content="";

try

{

consetAutoCommit(false);

stmt=concreateStatement();

ResultSet rs_clob=stmtexecuteQuery("select tcontent from table t where tid="+id);

oraclesqlCLOB contents=null;

while (rs_clobnext())

{ // 取出CLOB对象

contents= (oraclesqlCLOB) rs_clobgetClob(1);

}

BufferedReader a = new BufferedReader(contentsgetCharacterStream()); //以字符流的方式读入BufferedReader

String str = "";

while ((str = areadLine()) != null) {

content = contentconcat(str); //最后以String的形式得到

}

concommit();

/

BufferedWriter out = new BufferedWriter(new FileWriter("e:/testtxt"));

outwrite(content); //写入文件

outclose(); /

consetAutoCommit(true);

conclose();

}catch(Exception e)

{

Systemoutprintln("出现异常");

eprintStackTrace();

try

{

conrollback();

}

catch (Exception e1)

{

Systemoutprintln("回滚出现异常！");

e1printStackTrace();

}

}

return content;

}

<xml version="10" encoding="UTF-8" > <!DOCTYPE mapper PUBLIC "-//mybatisorg//DTD Mapper 30//EN" ">

以上就是关于java 大字符串转为二进制流存入CLOB字段 JDBC方法全部的内容，包括:java 大字符串转为二进制流存入CLOB字段 JDBC方法、mybatis如何读取clob数据 详细过程、java将string插入到类型为clob的ORACLE库中等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！