一。例子來自於一本書上:java
import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class MultiResultSet { public static void main(String[] args) { Connection conn = null; Statement stmt = null; // TODO Auto-generated method stub try { //裝載JDBC驅動 Class.forName("com.mysql.jdbc.Driver"); //鏈接字符串:包括數據庫服務器名、端口號(省略)、數據庫名、 String conStr = "jdbc:mysql://localhost/mydb?characterEncoding=UTF8&allowMultiQueries=true"; //得到Connection對象,進行鏈接數據庫:數據庫鏈接字符串,用戶名,密碼 conn = DriverManager.getConnection(conStr, "root", "123456"); //得到Statement對象:用來操做sql語句 stmt = conn.createStatement(); //創建一個圖書銷售表t_booksale String createDB = "create database if not exists mydb default character set utf8"; String dropTable = "drop table if exists mydb.t_booksale";//若是存在則刪除重建 String createTable = "create table mydb.t_booksale(" + "id int unsigned not null auto_increment,"+ "bookid int unsigned not null,"+ "amount int unsigned not null,"+ "saledate datetime not null,"+ "primary key(id)) engine=innodb default charset=utf8"; String insertData1 = "insert into mydb.t_booksale(bookid,amount,saledate) values(1,23,'1988-3-23')"; String insertData2 = "insert into mydb.t_booksale(bookid,amount,saledate) values(1,120,'2008-5-11')"; String insertData3 = "insert into mydb.t_booksale(bookid,amount,saledate) values(2,218,'2011-2-09')"; stmt.execute(createDB); stmt.execute(dropTable); stmt.execute(createTable); stmt.execute(insertData1); stmt.execute(insertData2); stmt.execute(insertData3); //返回多個結果集ResultSet,使用do while處理 String selectData = "select id,name,author from t_books" +";"+ "select bookid,amount,saledate from t_booksale"; if(stmt.execute(selectData)){ ResultSet rs = null; do{ rs = stmt.getResultSet(); //顯示查詢結果 while(rs.next()){ System.out.println(rs.getString(1));//得到id號 System.out.println(rs.getString(2));//做者名 System.out.println(rs.getString(3)); } }while(stmt.getMoreResults()); } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ try { if(stmt!=null){ stmt.close(); } if(conn!=null){ conn.close(); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }
二。遇到的問題mysql
鏈接字符串問題。處理多個結果集時,要加上allowMultiQueries=true。sql
sql語句混合寫時,要注意寫時的格式問題。數據庫
編碼問題服務器
Access denied for user 'root'@'localhost' (using password: YES)編碼
中止服務mysql----移除mysql服務-----安裝mysql服務--------啓動服務mysqlcode