10.6 管理结果集

目录：

一、可滚动、可更新的结果集

二、处理Blob类型数据

三、使用ResultSetMetaData分析结果集

一、可滚动、可更新的结果集

　　可以使用next()、absolute()、afterLast()、previous()等方法自由移动记录指针的ResultSet被称为可滚动的结果集。
　　以默认方式打开的ResultSet是不可更新的，如果希望创建可更新的ResultSet，则必须在创建Statement或prepareStatement时传入额外参数。Connection在创建Statement或PrepareStatement时还可额外传入如下两个参数：
1、resultSetType:控制ResultSet的类型，该参数可以取如下三个值
（1）ResultSet.TYPE_FORWARD_ONLY:该常量控制记录指针只能向前移动。这是JDK1.4以前的默认值。
（2）ResultSet.TYPE_SCROLL_INSENSITIVE:该常量控制指针可以自由移动（可滚动结果集），但底层数据的改变不会影响ResultSet的内容。
（3）ResultSet.TYPE_SCROLL_SENSITIVE:该常量控制记录指针可以自由记录（可滚动的结果集），而且底层数据的改变会影响ResultSet的内容。
2、resultSetConcurrency:控制ResultSet的并发类型，该参数可以接受如下两个值：
（1）ResultSet.CONCUR_READ_ONLY:该常量指示ResultSet是只读的并发模式（默认）。
（2）ResultSet.CONCUR_UPDATABLE:该常量指示ResultSet是可更新的并发模式。
下面创建一个PreparedStatement对象，由该对象生成的ResultSet对象将是可滚动、可更新的结果集。

//使用Connection创建一个PreparedStatement对象
//传入控制结果集可滚动、可更新的参数：
pstmt=conn.preparedStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);

可更新的结果集还需要满足如下两个条件：
★所有数据都应该来自一个表
★选出的数据集必须包含主键列
在创建了可滚动、可更新的ResultSet时，程序可调用ResultSet的updateXxx(int columnIndex,Xxx value)方法来修改执政所指记录、特定列的值，最后调用ResultSet的updateRow()方法来提交修改。
Java 8为ResultSet添加了updateObject(String columnLable,Object x,SQLType targetSqlType)和updateObject(int columnIndex,Object x,SQLType targetSqlObject)两个默认方法，这两个方法可以直接使用Object来修改记录指针所指记录、特定列的值，其中SQLType用于指定该数据列的类型。
下面示范创建这种可滚动、可更新的结果集的方法：

package section5;

import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Properties;

public class ResultSetTest
{
private String driver;
private String url;
private String user;
private String pass;
public void initParam(String paramFile)
throws Exception
{
//使用Properties类加载属性
var props=new Properties();
props.load(new FileInputStream(paramFile));
driver=props.getProperty("driver");
url=props.getProperty("url");
user=props.getProperty("user");
pass=props.getProperty("pass");
}
public void query(String sql)
throws Exception
{
//加载驱动
Class.forName(driver);
try(
//创建连接
Connection conn= DriverManager.getConnection(url,user,pass);
//创建结果集可滚动、可更新的参数
PreparedStatement pstmt=conn.prepareStatement(sql,
ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
ResultSet rs=pstmt.executeQuery()
)
{
rs.last();//指针记录定位到最后一行
int rowCount=rs.getRow();//查询由多少条记录
for(var i = rowCount;i>0;i--)
{
rs.absolute(i);//将记录指针移动到第i行
System.out.println(rs.getString(1)+"	"
+rs.getString(2)+"	"+rs.getString(3));
//修改记录指针所指记录第二列的值
rs.updateString(2,"学生名"+i);
//提交修改
rs.updateRow();
}
}
}
public static void main(String[] args)
throws Exception
{
var rt=new ResultSetTest();
rt.initParam("src\mysql.ini");
rt.query("select *from student_table;");
}
}

执行结果后查询数据表：

二、处理Blob类型数据

Blob（Binary Long Object）指的是二进制长对象，Blob列通常用于存储大文件，典型的Blob内容就是：图片、声音文件。使用Blob列可以把图片、声音等文件的二进制数据保存在数据库里，并可以从数据库里恢复指定文件。

回顾表的插入：

insert into teacher_table(teacher_id,teacher_name)
values(1,'Mike');

 试想如果有一列是Blob列，我们无法直接通过上面的SQL语句完成，因为Blob常量无法表示。

2.1 插入Blob数据

将Blob数据插入数据库需要使用PreparedStatement，该对象有一个方法：

setBinaryStream(int paramterIndex,inputStream x);
//该方法可以为指定参数传入二进制输入流

 2.2 取出Blob数据

当需要从ResultSet中取出Blob数据时，可以调用ResultSet的getBlob(int columnIndex)方法：

getBlob(int columnIndex);
//该方法返回一个Blob对象

在获取Blob对象后，Blob对象提供getBinaryStream()方法来获取该Blob数据的输入流，也可以使用Blob对象提供的getBytes()方法直接取出该Blob对象封装的二进制数据。

程序示例：

为了把图片放入数据库，先使用SQL语句创建一个数据表：

mysql> use select_test;
Database changed
mysql> create table img_table
    -> (img_id int auto_increment primary key,
    -> img_name varchar(255),
    -> img_data mediumblob);
Query OK, 0 rows affected (1.10 sec)

mysql> desc img_table;
+----------+--------------+------+-----+---------+----------------+
| Field    | Type         | Null | Key | Default | Extra          |
+----------+--------------+------+-----+---------+----------------+
| img_id   | int(11)      | NO   | PRI | NULL    | auto_increment |
| img_name | varchar(255) | YES  |     | NULL    |                |
| img_data | mediumblob   | YES  |     | NULL    |                |
+----------+--------------+------+-----+---------+----------------+
3 rows in set (0.03 sec)

 下面程序可以实现“上传”——实际上就是将图片保存到数据库，并在右边列表框中显式图片的名字，当用户双击列表框的图片名1时，左边窗口将显式该图片——实质上就是根据选中的ID从数据库里查找图片，并将其显示出来。

package section5;
import java.sql.*;
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
import java.util.Properties;
import java.util.ArrayList;
import java.io.*;
import javax.swing.filechooser.FileFilter;

public class BlobTest
{
    JFrame jf = new JFrame("图片管理程序");
    private static Connection conn;
    private static PreparedStatement insert;
    private static PreparedStatement query;
    private static PreparedStatement queryAll;
    // 定义一个DefaultListModel对象
    private DefaultListModel<ImageHolder> imageModel
            = new DefaultListModel<>();
    private JList<ImageHolder> imageList = new JList<>(imageModel);
    private JTextField filePath = new JTextField(26);
    private JButton browserBn = new JButton("...");
    private JButton uploadBn = new JButton("上传");
    private JLabel imageLabel = new JLabel();
    // 以当前路径创建文件选择器
    JFileChooser chooser = new JFileChooser(".");
    // 创建文件过滤器
    ExtensionFileFilter filter = new ExtensionFileFilter();
    static
    {
        try
        {
            var props = new Properties();
            props.load(new FileInputStream("src\mysql.ini"));
            var driver = props.getProperty("driver");
            var url = props.getProperty("url");
            var user = props.getProperty("user");
            var pass = props.getProperty("pass");

            Class.forName(driver);
            // 获取数据库连接
            conn = DriverManager.getConnection(url, user, pass);
            // 创建执行插入的PreparedStatement对象
            // 该对象执行插入后可以返回自动生成的主键
            insert = conn.prepareStatement("insert into img_table"
                    + " values(null, ?, ?)", Statement.RETURN_GENERATED_KEYS);
            // 创建两个PreparedStatement对象，用于查询指定图片，查询所有图片
            query = conn.prepareStatement("select img_data from img_table"
                    + " where img_id = ?");
            queryAll = conn.prepareStatement("select img_id, "
                    + "img_name from img_table");
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
    }
    public void init() throws SQLException
    {
        // -------初始化文件选择器--------
        filter.addExtension("jpg");
        filter.addExtension("jpeg");
        filter.addExtension("gif");
        filter.addExtension("png");
        filter.setDescription("图片文件(*.jpg, *.jpeg, *.gif, *.png)");
        chooser.addChoosableFileFilter(filter);
        // 禁止“文件类型”下拉列表中显示“所有文件”选项
        chooser.setAcceptAllFileFilterUsed(false);
        // ---------初始化程序界面---------
        fillListModel();
        filePath.setEditable(false);
        // 只能单选
        imageList.setSelectionMode(ListSelectionModel.SINGLE_SELECTION);
        var jp = new JPanel();
        jp.add(filePath);
        jp.add(browserBn);
        browserBn.addActionListener(event -> {
            // 显示文件对话框
            int result = chooser.showDialog(jf, "浏览图片文件上传");
            // 如果用户选择了APPROVE（赞同）按钮，即打开，保存等效按钮
            if (result == JFileChooser.APPROVE_OPTION)
            {
                filePath.setText(chooser.getSelectedFile().getPath());
            }
        });
        jp.add(uploadBn);
        uploadBn.addActionListener(avt -> {
            // 如果上传文件的文本框有内容
            if (filePath.getText().trim().length() > 0)
            {
                // 将指定文件保存到数据库
                upload(filePath.getText());
                // 清空文本框内容
                filePath.setText("");
            }
        });
        var left = new JPanel();
        left.setLayout(new BorderLayout());
        left.add(new JScrollPane(imageLabel), BorderLayout.CENTER);
        left.add(jp, BorderLayout.SOUTH);
        jf.add(left);
        imageList.setFixedCellWidth(160);
        jf.add(new JScrollPane(imageList), BorderLayout.EAST);
        imageList.addMouseListener(new MouseAdapter()
        {
            public void mouseClicked(MouseEvent e)
            {
                // 如果鼠标双击
                if (e.getClickCount() >= 2)
                {
                    // 取出选中的List项
                    ImageHolder cur = (ImageHolder) imageList.
                            getSelectedValue();
                    try
                    {
                        // 显示选中项对应的Image
                        showImage(cur.getId());
                    }
                    catch (SQLException sqle)
                    {
                        sqle.printStackTrace();
                    }
                }
            }
        });
        jf.setSize(620, 400);
        jf.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        jf.setVisible(true);
    }
    // ----------查找img_table填充ListModel----------
    public void fillListModel() throws SQLException
    {
        try (
                // 执行查询
                ResultSet rs = queryAll.executeQuery())
        {
            // 先清除所有元素
            imageModel.clear();
            // 把查询的全部记录添加到ListModel中
            while (rs.next())
            {
                imageModel.addElement(new ImageHolder(rs.getInt(1),
                        rs.getString(2)));
            }
        }
    }
    // ---------将指定图片放入数据库---------
    public void upload(String fileName)
    {
        // 截取文件名
        String imageName = fileName.substring(fileName.lastIndexOf('\')
                + 1, fileName.lastIndexOf('.'));
        var f = new File(fileName);
        try (
                var is = new FileInputStream(f))
        {
            // 设置图片名参数
            insert.setString(1, imageName);
            // 设置二进制流参数
            insert.setBinaryStream(2, is, (int) f.length());
            int affect = insert.executeUpdate();
            if (affect == 1)
            {
                // 重新更新ListModel，将会让JList显示最新的图片列表
                fillListModel();
            }
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
    }
    // ---------根据图片ID来显示图片----------
    public void showImage(int id) throws SQLException
    {
        // 设置参数
        query.setInt(1, id);
        try (
                // 执行查询
                ResultSet rs = query.executeQuery())
        {
            if (rs.next())
            {
                // 取出Blob列
                Blob imgBlob = rs.getBlob(1);
                // 取出Blob列里的数据
                var icon = new ImageIcon(imgBlob.getBytes(1L, (int) imgBlob.length()));
                imageLabel.setIcon(icon);
            }
        }
    }
    public static void main(String[] args) throws SQLException
    {
        new BlobTest().init();
    }
}
// 创建FileFilter的子类，用以实现文件过滤功能
class ExtensionFileFilter extends FileFilter
{
    private String description = "";
    private ArrayList<String> extensions = new ArrayList<>();
    // 自定义方法，用于添加文件扩展名
    public void addExtension(String extension)
    {
        if (!extension.startsWith("."))
        {
            extension = "." + extension;
            extensions.add(extension.toLowerCase());
        }
    }
    // 用于设置该文件过滤器的描述文本
    public void setDescription(String aDescription)
    {
        description = aDescription;
    }
    // 继承FileFilter类必须实现的抽象方法，返回该文件过滤器的描述文本
    public String getDescription()
    {
        return description;
    }
    // 继承FileFilter类必须实现的抽象方法，判断该文件过滤器是否接受该文件
    public boolean accept(File f)
    {
        // 如果该文件是路径，接受该文件
        if (f.isDirectory()) return true;
        // 将文件名转为小写（全部转为小写后比较，用于忽略文件名大小写）
        String name = f.getName().toLowerCase();
        // 遍历所有可接受的扩展名，如果扩展名相同，该文件就可接受
        for (var extension : extensions)
        {
            if (name.endsWith(extension))
            {
                return true;
            }
        }
        return false;
    }
}
// 创建一个ImageHolder类，用于封装图片名、图片ID
class ImageHolder
{
    // 封装图片的ID
    private int id;
    // 封装图片的名字
    private String name;
    public ImageHolder(){}
    public ImageHolder(int id, String name)
    {
        this.id = id;
        this.name = name;
    }
    // id的setter和getter方法
    public void setId(int id)
    {
        this.id = id;
    }
    public int getId()
    {
        return this.id;
    }
    // name的setter和getter方法
    public void setName(String name)
    {
        this.name = name;
    }
    public String getName()
    {
        return this.name;
    }
    // 重写toString()方法，返回图片名
    public String toString()
    {
        return name;
    }
}

三、使用ResultSetMetaData分析结果集

提示：MetaData意思就是元数据，即描述其他数据的数据，因此ResultSetMetaData封装了描述ResultSet对象的数据。

ResultSet里包含一个getMetaData()方法，该方法返回改ResultSetMetaData对象。通过ResultSetMetaData对象提供的大量方法来返回ResultSet的描述信息：

（1）int getColumnCount():返回该ResultSet列数量。

（2）String getColumnName(int column):返回指定索引的列类型。

（3）int getColumnType(int column):返回指定索引的列类型。

ResultSet里有一个方法返回记录条数：

（1）getRow():返回数据表的记录指针前面的记录条数。先执行ResultSet的方法last()将记录指针移到最后。

package section5;

import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.util.Properties;

public class MetaDataTest
{
    private String driver;
    private String url;
    private String user;
    private String pass;

    public void initParam(String fileName)
        throws Exception
    {
        //使用Properties类加载属性
        Properties props=new Properties();
        props.load(new FileInputStream(fileName));
        driver=props.getProperty("driver");
        url=props.getProperty("url");
        user=props.getProperty("user");
        pass=props.getProperty("pass");
    }
    public void queryMetaData(String sql)
        throws Exception
    {
        //加载驱动
        Class.forName(driver);
        try(
                //获取连接
                Connection conn=DriverManager.getConnection(url,user,pass);
                var cstmt=conn.createStatement();
                ResultSet rs=cstmt.executeQuery(sql)
                )
        {
            rs.last();
            ResultSetMetaData rsmd=rs.getMetaData();
            int columns=rsmd.getColumnCount();
            System.out.println("记录条数："+rs.getRow());
            System.out.println("数据表的列数："+columns);
            for(int i=1;i<=columns;i++)
            {
                System.out.print(i+":"+rsmd.getColumnName(i)+"	");
            }
            System.out.println();
            //遍历数据表
            rs.beforeFirst();
            while(rs.next())
            {
                System.out.println(rs.getInt(1)+"	"+rs.getString(2));
            }
        }
    }
    public static void main(String[] args)
            throws Exception
    {
        var mdt=new MetaDataTest();
        mdt.initParam("src\mysql.ini");
        mdt.queryMetaData("select * from teacher_table;");

    }
}
执行结果：
记录条数：3
数据表的列数：2
1:teacher_id    2:teacher_name    
1    Yeeku
2    Leegang
3    Martine

Process finished with exit code 0