jdbc autocommit 能?哪个不是jdbc用到的接口和类
一、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();
就是上面