oracle查询可更新结果集,jdbc可更新结果集

jdbc中ResultSet在jdk 5.0以后默认都是可滚动的&＃xff0c;不可更新的。可滚动的意思是我们可以调用absolute()&＃xff0c;previous(),  first()等操作来更新结果集中的指针位置。

当我们需要结果集可更新的时候&＃xff0c;可以设置它的值为ResultSet.CONCUR_UPDATABLE&＃xff0c;默认是ResultSet.CONCUR_READ_ONLY。

当我们在连接的是oracle数据库时&＃xff0c;如果查询的sql语句是select * from 表名的话&＃xff0c;那么oracle默认我们是以只读方式访问表&＃xff0c;所以我们程序设置为可更新的结果集&＃xff0c;也是没有任何用处的&＃xff0c;需要select 字段名..... from 表名&＃xff0c;才能调用可更新的结果集。

下面我们演示 更新结果集的操作&＃xff0c;把表的sname列&＃xff0c;更新为“姓名”&＃43;i。

package com.shizhan.main;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import com.shizhan.util.DatabaseUtil;

public class TestResult {

/**

* &＃64;param args

*/

public static void main(String[] args) {

Connection conn &＃61; null;

PreparedStatement ps &＃61; null;

ResultSet rs &＃61; null;

//当操作oracle数据库的时候&＃xff0c;如果设置结果集是可更新的&＃xff0c;则sql语句设置为select *from 表名&＃xff0c;是无法更新的&＃xff0c;需要设置select

//字段1&＃xff0c;字段2.。。from表名

String sql &＃61;"select sno,sname from student";

try {

conn &＃61; DatabaseUtil.getConnection();

//ResultSet.TYPE_SCROLL_INSENSITIVE结果集可滚动

//ResultSet.CONCUR_UPDATABLE结果集可更新

ps &＃61; conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE,

ResultSet.CONCUR_UPDATABLE);

rs &＃61; ps.executeQuery();

//指针移动到最后

rs.last();

//返回当前的行号

int rownum &＃61; rs.getRow();

for(int i&＃61;rownum;i>0;i--)

{

//指针移动到第i条记录

rs.absolute(i);

System.out.println("sno:"&＃43;rs.getInt(1)

&＃43;"\t"&＃43;"sname"&＃43;rs.getString(2));

//修改第二列的值

rs.updateString(2,"姓名"&＃43;i);

//提交修改&＃xff0c;更新列

rs.updateRow();

}

} catch (SQLException e) {

e.printStackTrace();

} catch (Exception e) {

e.printStackTrace();

}finally{

DatabaseUtil.close(rs);

DatabaseUtil.close(ps);

DatabaseUtil.close(conn);

}

}

}

package com.shizhan.util;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

public class DatabaseUtil {

static Connection connection &＃61; null;

static String driver &＃61; "oracle.jdbc.driver.OracleDriver";

static String url &＃61; "jdbc:oracle:thin:localhost:1521:orcl";

static String username &＃61;"scott";

static String password &＃61;"tiger";

public static Connection getConnection() throws Exception

{

Class.forName(driver);

connection &＃61; DriverManager.getConnection(url,username,password);

return connection;

}

public static void close(Connection conn) {//关闭连接对象

if(conn !&＃61; null) {//如果conn连接对象不为空

try {

conn.close();//关闭conn连接对象对象

} catch (SQLException e) {

e.printStackTrace();

}

}

}

public static void close(PreparedStatement pstmt) {//关闭预处理对象

if(pstmt !&＃61; null) {//如果pstmt预处理对象不为空

try {

pstmt.close();//关闭pstmt预处理对象

} catch (SQLException e) {

e.printStackTrace();

}

}

}

public static void close(Statement pstmt) {//关闭预处理对象

if(pstmt !&＃61; null) {//如果pstmt预处理对象不为空

try {

pstmt.close();//关闭pstmt预处理对象

} catch (SQLException e) {

e.printStackTrace();

}

}

}

public static void close(ResultSet rs) {//关闭结果集对象

if(rs !&＃61; null) {//如果rs结果集对象不为null

try {

rs.close();//关闭rs结果集对象

} catch (SQLException e) {

e.printStackTrace();

}

}

}

}