结果集(ResultSet)是数据中查询结果返回的一种对象,能够说结果集是一个存储查询结果的对象,可是结果集并不只仅具备存储的功能,他同时还具备操纵数据的功能,可能完成对数据的更新等.java
结果集读取数据的方法主要是getXXX(),他的参数可使整型表示第几列(是从1开始的),还能够是列名.返回的是对应的XXX类型的值.若是对应那列时空值,XXX是对象的话返回XXX型的空值,若是XXX是数字类型,如Float等则返回0,boolean返回false.使用getString()能够返回全部的列的值,不过返回的都是字符串类型的.XXX能够表明的类型有:基本的数据类型如整型(int),布尔型(Boolean),浮点型(Float,Double)等,比特型(byte),还包括一些特殊的类型,如:日期类型(java.sql.Date),时间类型(java.sql.Time),时间戳类型(java.sql.Timestamp),大数型(BigDecimal和BigInteger等)等.还可使用getArray(int colindex/String columnname),经过这个方法得到当前行中,colindex所在列的元素组成的对象的数组.使用getAsciiStream(int colindex/String colname)能够得到该列对应的当前行的ascii流.也就是说全部的getXXX方法都是对当前行进行操做.mysql
结果集从其使用的特色上能够分为四类,这四类的结果集的所具有的特色都是和Statement语句的建立有关,由于结果集是经过Statement语句执行后产生的,因此能够说,结果集具有何种特色,彻底决定于Statement,固然我是说下面要将的四个特色,在Statement建立时包括三种类型.首先是无参数类型的,他对应的就是下面要介绍的基本的ResultSet对应的Statement.下面的代码中用到的Connection并无对其初始化,变量conn表明的就是Connection对应的对象.SqlStr表明的是响应的SQL语句.sql
1.最基本的ResultSet.数据库
之因此说是最基本的ResultSet是由于,这个ResultSet他起到的做用就是完成了查询结果的存储功能,并且只能读去一次,不可以来回的滚动读取.这种结果集的建立方式以下:数组
Statement st = conn.CreateStatement测试
ResultSet rs = Statement.excuteQuery(sqlStr);url
因为这种结果集不支持,滚动的读去功能因此,若是得到这样一个结果集,只能使用它里面的next()方法,逐个的读去数据.spa
2.可滚动的ResultSet类型.指针
这个类型支持先后滚动取得纪录next(),previous(),回到第一行first(),同时还支持要去的ResultSet中的第几行absolute(int n),以及移动到相对当前行的第几行relative(int n),要实现这样的ResultSet在建立Statement时用以下的方法.code
Statement st = conn.createStatement(int resultSetType, int resultSetConcurrency)
ResultSet rs = st.executeQuery(sqlStr)
其中两个参数的意义是:
resultSetType是设置ResultSet对象的类型可滚动,或者是不可滚动.取值以下:
ResultSet.TYPE_FORWARD_ONLY只能向前滚动
ResultSet.TYPE_SCROLL_INSENSITIVE和Result.TYPE_SCROLL_SENSITIVE这两个方法都可以实现任意的先后滚动,使用各类移动的ResultSet指针的方法.两者的区别在于前者对于修改不敏感,然后者对于修改敏感.
resultSetConcurency是设置ResultSet对象可以修改的,取值以下:
ResultSet.CONCUR_READ_ONLY 设置为只读类型的参数.
ResultSet.CONCUR_UPDATABLE 设置为可修改类型的参数.
因此若是只是想要能够滚动的类型的Result只要把Statement以下赋值就好了.
Statement st = conn.createStatement(Result.TYPE_SCROLL_INSENITIVE,ResultSet.CONCUR_READ_ONLY);
ResultSet rs = st.excuteQuery(sqlStr);
用这个Statement执行的查询语句获得的就是可滚动的ResultSet.
3.可更新的ResultSet
这样的ResultSet对象能够完成对数据库中表的修改,可是我知道ResultSet只是至关于数据库中表的视图,因此并不时全部的ResultSet只要设置了可更新就可以完成更新的,可以完成更新的ResultSet的SQL语句必需要具有以下的属性:
a,只引用了单个表.
b,不含有join或者group by子句.
c,那些列中要包含主关键字.
具备上述条件的,可更新的ResultSet能够完成对数据的修改,可更新的结果集的建立方法是:
Statement st = createstatement(Result.TYPE_SCROLL_INSENSITIVE,Result.CONCUR_UPDATABLE)
这样的Statement的执行结果获得的就是可更新的结果集.更新的方法是,把ResultSet的游标移动到你要更新的行,而后调用updateXXX(),这个方法XXX的含义和getXXX()是相同的.updateXXX()方法,有两个参数,第一个是要更新的列,能够是列名或者序号.第二个是要更新的数据,这个数据类型要和XXX相同.每完成对一行的update要调用updateRow()完成对数据库的写入,并且是在ResultSet的游标没有离开该修改行以前,不然修改将不会被提交.
使用updateXXX方法还能够完成插入操做.可是首先要介绍两个方法:
moveToInsertRow()是把ResultSet移动到插入行,这个插入行是表中特殊的一行,不须要指定具体那一行,只要调用这个方法系统会自动移动到那一行的.
moveToCurrentRow()这是把ResultSet移动到记忆中的某个行,一般当前行.若是没有使用insert操做,这个方法没有什么效果,若是使用了insert操做,这个方法用于返回到insert操做以前的那一行,离开插入行,固然也能够经过next(),previous()等方法离开插入行.
要完成对数据库的插入,首先调用moveToInsertRow()移动到插入行,而后调用updateXXX的方法完成对,各列数据的更新,完成更新后和更新操做同样,要写到数据库,不过这里使用的是insertRow(),也要保证在该方法执行以前ResultSet没有离开插入列,不然插入不被执行,而且对插入行的更新将丢失.
4.可保持的ResultSet
正常状况下若是使用Statement执行完一个查询,又去执行另外一个查询时这时候第一个查询的结果集就会被关闭,也就是说,全部的Statement的查询对应的结果集是一个,若是调用Connection的commit()方法也会关闭结果集.可保持性就是指当ResultSet的结果被提交时,是被关闭仍是不被关闭.JDBC2.0和1.0提供的都是提交后ResultSet就会被关闭.不过在JDBC3.0中,咱们能够设置ResultSet是否关闭.要完成这样的ResultSet的对象的建立,要使用的Statement的建立要具备三个参数,这个Statement的建立方式也就是,我所说的Statement的第三种建立方式.以下:
Statement st=createStatement(int resultsetscrollable,int resultsetupdateable,int resultsetSetHoldability)
ResultSet rs = st.excuteQuery(sqlStr);
前两个参数和两个参数的createStatement方法中的参数是彻底相同的,这里只介绍第三个参数:
resultSetHoldability表示在结果集提交后结果集是否打开,取值有两个:
ResultSet.HOLD_CURSORS_OVER_COMMIT:表示修改提交时,不关闭数据库.
ResultSet.CLOSE_CURSORS_AT_COMMIT:表示修改提交时ResultSet关闭.
不过这种功能只是在JDBC3.0的驱动下才能成立.
Connection物件是表明Java与资料库的连线,接下来咱们要执行SQL的话,必须取得 Statement物件,它代替您执行SQL叙述并取得执行以后的结果,您可使用Connection的createStatement()来创建Statement物件:
Connection conn = DriverManager.getConnection(url, user, password);
Statement stmt = conn.createStatement();
取得Statement物件以后,咱们可使用executeUpdate(),executeQuery()等方法来执行 SQL,executeUpdate()主要是用来执行CREATE TABLE,INSERT,DROP TABLE,ALTER TABLE等会改变资料库内容的SQL,例如:
stmt.executeUpdate("INSERT INTO message VALUES(‘xxx‘, " + "‘xxx@mail.com‘, ‘留言吧‘, ‘2007-05-15‘," +"‘顶‘)");
executeQuery()方法则是用于SELECT等查询资料库的SQL,executeUpdate()与 executeQuery()都会传回ResultSet物件,表明变动或查询的结果,查询的结果会是一笔一笔的资料,您使用next()来移动至下一笔资料,它会传回 true 或 false表示是否有下一笔资料,接着可使用getXXX()来取得资料,例如getString(),getFloat(),getDouble()等方法,分别取得相对应的栏位型态资料,getXXX()方法都提供有依栏位名称取得资料,或是依栏位顺序取得资料的方法,一个例子以下,您指定栏位名称来取得资料:
ResultSet result = stmt.executeQuery("SELECT * FROM message");
while(result.next()) ...{
System.out.print(result.getString("name") + " ");
System.out.print(result.getString("email") + " ");
System.out.print(result.getString("subject") + " ");
System.out.print(result.getString("time") + " ");
System.out.println(result.getString("memo") + " ");
}
使用查询到的结果之栏位顺序来显示结果的方式以下:
ResultSet result = stmt.executeQuery("SELECT * FROM message");
while(result.next()) ...{
System.out.print(result.getString(1) + " ");
System.out.print(result.getString(2) + " ");
System.out.print(result.getString(3) + " ");
System.out.print(result.getString(4) + " ");
System.out.println(result.getString(5) + " ");
}
Statement的execute()能够用来执行SQL,并能够测试所执行的SQL是执行查询或是更新,传回 true的话表示SQL执行将传回ResultSet表示查询结果,此时可使用getResultSet()取得ResultSet物件,若是 execute()传回false,表示SQL执行会传回更新笔数或没有结果,此时可使用getUpdateCount()取得更新笔数.若是事先没法得知是进行查询或是更新,就可使用execute().
下面是个完整的范例,注意咱们在查询结束后,可使用Statement的close()方法来释放Statement的资料库资源与JDBC资源,而最后不使用连线时也使用Connection的close()来关闭连线:
DBTest.java
package onlyfun.caterpillar;
import java.sql.*;
public class DBTest ...{
public static void main(String[] args) ...{
String driver = "com.mysql.jdbc.Driver";
String url = "jdbc:mysql://localhost:3306/GUESTBOOK?" + "useUnicode=true&characterEncoding=Big5" ;
String user = "caterpillar";
String password = "123456";
Connection conn = null;
Statement stmt = null;
try ...{
Class.forName(driver);
conn = DriverManager.getConnection(URL, user, password);
stmt = conn.createStatement();
stmt.execute("INSERT INTO message VALUES(‘xxx" +
"‘, ‘xxx@mail.com‘, ‘留言吧‘, "+ "‘2007-05-15‘, ‘顶‘)");
ResultSet result = stmt.executeQuery("SELECT * FROM message");
while(result.next()) ...{
System.out.print(result.getString(1) + " ");
System.out.print(result.getString(2) + " ");
System.out.print(result.getString(3) + " ");
System.out.print(result.getString(4) + " ");
System.out.println(result.getString(5) + " ");
}
}catch(ClassNotFoundException e) ...{
System.out.println("找不到驱动程式");
e.printStackTrace();
}catch(SQLException e) ...{
e.printStackTrace();
}finally ...{
if(stmt != null) ...{
try ...{
stmt.close();
}catch(SQLException e) ...{
e.printStackTrace();
}
}
if(conn != null) ...{
try ...{
conn.close();
}catch(SQLException e) ...{
e.printStackTrace();
}
}
}
}
}
最后注意的是,Connection物件预设为自动"承认"(Commit),也就是Statement执行SQL叙述完后,立刻对资料库进行操做变动,若是想要对Statement要执行的SQL进行除错,可使用setAutoCommit(false)来将自动承认取消,在执行完SQL以后,再呼叫Connection的commit()方法承认变动,使用Connection的getAutoCommit()能够测试是否设定为自动承认.
不过不管是否有无执行commit()方法,只要SQL没有错,在关闭Statement或Connection前,都会执行承认动做,对资料库进行变动.