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

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

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

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

下面我们演示 更新结果集的操作，把表的sname列，更新为“姓名”+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 {

/**

* @param args

*/

public static void main(String[] args) {

Connection conn = null;

PreparedStatement ps = null;

ResultSet rs = null;

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

//字段1，字段2.。。from表名

String sql ="select sno,sname from student";

try {

conn = DatabaseUtil.getConnection();

//ResultSet.TYPE_SCROLL_INSENSITIVE结果集可滚动

//ResultSet.CONCUR_UPDATABLE结果集可更新

ps = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE,

ResultSet.CONCUR_UPDATABLE);

rs = ps.executeQuery();

//指针移动到最后

rs.last();

//返回当前的行号

int rownum = rs.getRow();

for(int i=rownum;i>0;i--)

{

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

rs.absolute(i);

System.out.println("sno:"+rs.getInt(1)

+"\t"+"sname"+rs.getString(2));

//修改第二列的值

rs.updateString(2,"姓名"+i);

//提交修改，更新列

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 = null;

static String driver = "oracle.jdbc.driver.OracleDriver";

static String url = "jdbc:oracle:thin:localhost:1521:orcl";

static String username ="scott";

static String password ="tiger";

public static Connection getConnection() throws Exception

{

Class.forName(driver);

connection = DriverManager.getConnection(url,username,password);

return connection;

}

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

if(conn != null) {//如果conn连接对象不为空

try {

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

} catch (SQLException e) {

e.printStackTrace();

}

}

}

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

if(pstmt != null) {//如果pstmt预处理对象不为空

try {

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

} catch (SQLException e) {

e.printStackTrace();

}

}

}

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

if(pstmt != null) {//如果pstmt预处理对象不为空

try {

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

} catch (SQLException e) {

e.printStackTrace();

}

}

}

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

if(rs != null) {//如果rs结果集对象不为null

try {

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

} catch (SQLException e) {

e.printStackTrace();

}

}

}

}