jdbc autocommit 能?哪个不是jdbc用到的接口和类

seosqwseo2个月前 (09-14)测评日记35

一、jdbc中如何处理OracleBLOB字段

一般人会走哪些弯路? 1.使用jdk中的方法进行传输。在ResultSet中有getBlob()方法,在PreparedStatement中有setBlob()方法,所以大多数人都会尝试setBlob(),getBlob()进行读写,或者两个数据库之间BLOB的传输。这种方法实际上是行不通的,据网上的一些资

一般人会走哪些弯路?

1.使用jdk中的方法进行传输。在ResultSet中有getBlob()方法,在PreparedStatement中有setBlob()方法,所以大多数人都会尝试setBlob

(),getBlob()进行读写,或者两个数据库之间BLOB的传输。这种方法实际上是行不通的,据网上的一些资料介绍,说sun官方的文档有些方法

都是错误的。

2.使用ResultSet.getBinaryStream和PreparedStatement.setBinaryStream对BLOB进行读写或两个数据库间的传输。这种方法我自己尝试过,

发现,如果BLOB中存储的是文本文件的话,就没问题,如果是二进制文件,传输就会有问题。

根据自己的经验,以及查阅了Oracle的官方文档,都是使用如下处理方法:

1.新建记录,插入BLOB数据

1.1首先新建记录的时候,使用oracle的函数插入一个空的BLOB,假设字段A是BLOB类型的:

insert xxxtable(A,B,C) values(empty_blob(),'xxx','yyyy')

1.2后面再查询刚才插入的记录,然后更新BLOB,在查询前,注意设置Connection的一个属性:

conn.setAutoCommit(false);如果缺少这一步,可能导致fetch out of sequence等异常.

1.3查询刚才插入的记录,后面要加“ for update”,如下:

select A from xxxtable where xxx=999 for update,如果缺少for update,可能出现row containing the LOB value is not locked

的异常

1.4从查询到的 BLOB字段中,获取blob并进行更新,代码如下:

BLOB blob=(BLOB) rs.getBlob("A");

OutputStream os= blob.getBinaryOutputStream();

BufferedOutputStream output= new BufferedOutputStream(os);

后面再使用output.write方法将需要写入的内容写到output中就可以了。例如我们将一个文件写入这个字段中:

BufferedInputStream input= new BufferedInputStream(new File("c://hpWave.log").toURL().openStream());

byte[] buff= new byte[2048];//用做文件写入的缓冲

int bytesRead;

while(-1!=(bytesRead= input.read(buff, 0, buff.length))){

output.write(buff, 0, bytesRead);

System.out.println(bytesRead);

}

上面的代码就是从input里2k地读取,然后写入到output中。

1.5上面执行完毕后,记得关闭output,input,以及关闭查询到的ResultSet

1.6后执行connmit();将更新的内容提交,以及执行conn.setAutoCommit(true);改回Connction的属性

2.修改记录,方法与上面的方法类似,

2.1首先更新BLOB以外的其他字段

2.2使用1.3中类似的方法获取记录

2.3修改的过程中,注意以下:a需要更新的记录中,BLOB有可能为NULL,这样在执行blob.getBinaryOutputStream()获取的值可能为

null,那么就关闭刚才select的记录,再执行一次update xxxtable set A= empty_blob() where xxx,这样就先写入了一个空的BLOB(不是null),然后再

使用1.3,1.4中的方法执行更新记录.b注意别忘了先执行setAutoCommit(false),以及"for update",以及后面的connmit();等。

3.读取BLOB字段中的数据.

3.1读取记录不需要setAutoCommit(),以及 select....for update.

3.2使用普通的select方法查询出记录

3.3从ResultSet中获取BLOB并读取,如下:

BLOB b_to=(BLOB) rs.getBlob("A");

InputStream is= b_from.getBinaryStream();

BufferedInputStream input= new BufferedInputStream(is);

byte[] buff= new byte[2048];

while(-1!=(bytesRead= input.read(buff, 0, buff.length))){

//在这里执行写入,如写入到文件的BufferedOutputStream里

System.out.println(bytesRead);

}

通过循环取出blob中的数据,写到buff里,再将buff的内容写入到需要的地方

4.两个数据库间blob字段的传输

类似上面1和3的方法,一边获取BufferedOutputStream,另外一边获取BufferedInputStream,然后读出写入,需要注意的是写入所用的

Connection要执行conn.setAutoCommit(false);以及获取记录时添加“ for update”以及后的commit();

总结以上方法,其根本就是先创建空的BLOB,再获取其BufferedOutputStream进行写入,或获取BufferedInputStream进行读取

2007-6-23 19:45:02

查看评语???

2007-6-23 19:48:30 java语言*作Oracle数据库中的CLOB数据类型字段类型:blob,clob,nclob

说明:三种大型对象(LOB),用来保存较大的图形文件或带格式的文本文件,如Miceosoft Word文档,以及音频、视频等非文本文件,大长度是4GB。LOB有几种类型,取决于你使用的字节的类型,Oracle 8i实实在在地将这些数据存储在数据库内部保存。可以执行读取、存储、写入等特殊*作。

我们所*作的clobtest_table中属性是(字符型id,CLOB型picstr),目前我们假设一个大的字符对象str已经包含了我们需要存入picstr字段的数据。而且connection对象conn已经建立。以下的例子程序也因为不想占用太多的空间,所以对抛出异常没有写。大家参考一下api doc。就可以知道该抛出什么异常了,此处仅仅告诉大家如何去写。

代码:

(1)对数据库clob型执行插入*作

*************************************************

java.sql.PreparedStatement pstmt= null;

ResultSet rs= null;

String query="";

conn.setAutoCommit(false);

query="insert into clobtest_table(id,picstr) values(?,empty_clob())";

java.sql.PreparedStatement pstmt= conn.prepareStatement(query);

pstmt.setString(1,"001");

pstmt.executeUpdate();

pstmt= null

query="select picstr from clobtest_table where id='001' for update";

pstmt= con.prepareStatement(query)

rs= pstmt.executeQuery();

oracle.sql.CLOB clobtt= null;

if(rs.next()){

clobtt=(oracle.sql.CLOB)rs.getClob(1);

}

Writer wr= clobtt.getCharacterOutputStream();

wr.write(strtmp);

wr.flush();

wr.close();

rs.close();

conmit();

(2)通过sql/plus查询是否已经成功插入数据库

*************************************************

PL/SQL的包DBMS_LOB来处理LOB数据。察看刚才的插入是否成功。使用DBMS_LOB包的getlength这个procedure来检测是否已经将str存入到picstr字段中了。如:

SQL> select dbms_lob.getlength(picstr) from clobtest_table;

(3)对数据库clob型执行读取*作

*************************************************

读取相对插入就很简单了。基本步骤和一半的取数据库数据没有太大的差别。

String description=""

query="select picstr from clobtest_table where id='001'";

pstmt= con.prepareStatement(query);

ResultSet result= pstmt.executeQuery();

if(result.next()){

oracle.jdbc.driver.OracleResultSet ors=

(oracle.jdbc.driver.OracleResultSet)result;

oracle.sql.CLOB clobtmp=(oracle.sql.CLOB) ors.getClob(1);

if(clobtmp==null|| clobtmp.length()==0){

System.out.println("======CLOB对象为空");

description="";

}else{

description=clobtmp.getSubString((long)1,(int)clobtmp.length());

System.out.println("======字符串形式"+description);

}

}

二、哪个不是jdbc用到的接口和类

以下是JDBC常用接口和类,楼主自己对应吧:

DriverManager:用于管理JDBC驱动的服务类。程序中使用该类的的主要功能是获取Connection对象,该类包含如下方法:

public static Connection

getConnection(String url, String user, String password) throws SQLException

该方法获得url对应数据库的连接;

Connection:代表数据库连接对象,每个Connection代表一个物理连接会话。要想访问数据库,必须先得到数据库连接。该接口的常用方法如下:

Statement

createStatement() throws SQLException;该方法返回一个Statement对象;

PreparedStatement

prepareStatement(String sql)throws SQLException;该方法返回预编译的Statement对象,即将SQL语句提交到数据库进行预编译;

CallableStatement

prepareCall(String sql) throws SQLException;

该方法返回CallableStatement对象,该对象用于调用存储过程。

上面上个方法都返回用于执行sql语句的Statement对象,PreparedStatement和CallableStatement是Statement的子类,只有获得了Statement之后才可以执行sql语句;

除此之外,Connection还有如下几个用于控制事务的方法。

Savepoint

setSavepoint() throws SQLException;创建一个保存点;

Savepoint

setSavepoint(String name) throws SQLException;以指定名字来创建一个保存点;

void

setTransactionIsolation(int level) throws SQLException;设置事务的隔离级别;

void

rollback() throws SQLException;回滚事务;

void

rollback(Savepoint savepoint) throws SQLException;将事务回滚到指定的保存点;

void

setAutoCommit(boolean autoCommit) throws SQLException;关闭自动提交,打开事务;

void

commit() throws SQLException;提交事务;

Statement:用于执行sql语句的工具接口。该对象既可以执行DDL,DCL语句,也可以用于执行DML语句,还可以用于执行sql查询。当执行sql查询时,返回查询到的结果集。它的常用方法如下:

ResultSet

executeQuery(String sql) throws SQLException;该方法用于执行查询语句,并返回查询结果对应ResultSet对象。该方法只能用于执行查询语句。

int executeUpdate(String sql) throws SQLException;该方法用于执行DML语句,并返回受影响的行数;该方法也可用于执行DDL语句,执行DDL语句将返回0;

boolean

execute(String sql) throws SQLException;改方法可以执行任何sql语句。如果执行后第一个结果为ResultSet对象,则返回true;如果执行后第一个结果为受影响的行数或没有任何结果,则返回false;

PreparedStatement:预编译的Statement对象,PreparedStatement是Statement的子接口,它允许数据库预编译sql语句(这些sql语句通常带有参数),以后每次只改变sql命令的参数,避免数据库每次都需要编译sql语句,无需再传入sql语句,

只要为预编译的sql语句传入参数值即可。所以它比Statement多了如下方法:

void

setXxx(int parameterIndex, Xxx value):该方法根据传入参数值的类型不同,需要使用不同的方法。传入的值根据索引传给sql语句中指定位置的参数。

ResultSet:结果集对象。该对象包含访问查询结果的方法,ResultSet可以通过列索引或列名获得列数据。它包含了如下常用方法来移动记录指针。

void

close() throws SQLException;释放ResultSet对象;

boolean

absolute( int row) throws SQLException;将结果集的记录指针移动到第row行,如果row是负数,则移动到倒数第row行,如果移动后的记录指针指向一条有效记录,则该方法返回true;

boolean

next() throws SQLException;将结果集的记录指针定位到下一行,如果移动后的记录指针指向一条有效的记录,则该方法返回true;

boolean

last() throws SQLException;将结果集的记录指针定位到后一行,如果移动后的记录指针指向一条有效的记录,则该方法返回true;

三、jdbc PreparedStatement executeBatch方法执行效率低的问题

按说效率不会低到这种地步,你执行的是insert语句我很想知道你目前的代码有没有开启手动提交事务,如果你是自动提交事务那么可能会导致这800多条会执行一条提交一次事务,导致时间全部浪费在这里了,你可以尝试一下手动提交事务,等executebatch执行了然后提交事务。

conn.setAutoCommit= false;

//...............

代码

connmit();

就是上面

相关文章

HQisQnse海迅商显会议平板电视55英寸教学会议一体机触控触摸电视教育培训显示屏Windows怎么样?质量测评好不好用?

HQisQnse海迅商显会议平板电视55英寸教学会议一体机触控触摸电视教育培训显示屏Windows怎么样?质量测评好不好用?

很多小伙伴在关注HQisQnse海迅商显会议平板电视55英寸教学会议一体机触控触摸电视教育培训显示屏Windows怎么样?质量好不好?使用测评如何?本文综合已购用户的客观使...

小米(MI)ES43图文测评

小米(MI)ES43图文测评

很多小伙伴在关注小米(MI)ES43怎么样?质量好不好?使用测评如何?本文综合已购用户的客观使用分享和相应的优惠信息,为大家推荐一款高性价比的产品,一起来看看吧。...

六品堂课程专拍链接质量好不好

六品堂课程专拍链接质量好不好

很多小伙伴在关注六品堂课程专拍链接怎么样?质量好不好?使用测评如何?本文综合已购用户的客观使用分享和相应的优惠信息,为大家推荐一款高性价比的产品,一起来看看吧。...

Apple苹果耳机有线原装线控手机耳机13/14耳塞入耳式XR有线耳机耳麦iPhone12ProMax/11/SE/8p/earpods质量好吗

Apple苹果耳机有线原装线控手机耳机13/14耳塞入耳式XR有线耳机耳麦iPhone12ProMax/11/SE/8p/earpods质量好吗

很多小伙伴在关注Apple苹果耳机有线原装线控手机耳机13/14耳塞入耳式XR有线耳机耳麦iPhone12ProMax/11/SE/8p/earpods怎么样?质量好不好?...

闪迪(SanDisk)128GBTF(MicroSD)存储卡口碑好不好

闪迪(SanDisk)128GBTF(MicroSD)存储卡口碑好不好

很多小伙伴在关注闪迪(SanDisk)128GBTF(MicroSD)存储卡怎么样?质量好不好?使用测评如何?本文综合已购用户的客观使用分享和相应的优惠信息,为大家推荐一款...

佳能(Canon)EOS6D好不好

佳能(Canon)EOS6D好不好

很多小伙伴在关注佳能(Canon)EOS6D怎么样?质量好不好?使用测评如何?本文综合已购用户的客观使用分享和相应的优惠信息,为大家推荐一款高性价比的产品,一起来看看吧。...