C金沙官网线上# SqlBulkCopy数据批量入库

准备条件:20万+数据

事件派发线程(EDT)

理解SwingUtilities类作用的前提是先理解事件派发线程的概念。
当运行一个 Swing 程序时,会自动创建三个线程。
1.主线程,负责执行main 方法。

  1. toolkit 线程,负责捕捉系统事件,比如键盘、鼠标移动等,程序员不会有任何代码在这个线程上执行。Toolkit线程的作用是把自己捕获的事件传递给第三个线程,也就是事件派发线程。
  2. 事件派发线程(EDT,Event Dispatcher Thread),顾名思义是用来派发事件(根据事件找到对应的事件处理代码)的线程。EDT接收来自 toolkit 线程的事件,并且将这些事件组织成一个队列,EDT的工作内容就是将这个队列中的事件按照顺序派发给相应的事件监听器,并且调用事件监听器中的回调函数,这也意味着,所有的事件处理代码都是在EDT而不是主线程中执行。
    上面说到EDT中维护了一个事件的队列,并且它们是按照顺序派发的。由于事件派发是单线程的操作,所以只有等待前面事件监听器的回调函数执行完毕,才能够执行组件更新的操作,以及继续派发后面的事件。这样导致的一个后果就是:当在一个事件监听回调函数中做了耗时的操作,那么,界面会因此停住,并且界面上所有控件失效(不可触发)。
    解决这个问题的方法是:在事件处理函数中将耗时的操作放到新线程(一般称之为工作线程)中执行,而不是让其在EDT中执行。比如下面的例子。

界面设计使用的WPF。

案例

一个窗口,有一个按钮和一个label。点击按钮,系统将做模仿导入数据的动作,导入数据之前需要检测数据的合法性。并且,检测数据和导入数据这两个步骤都需要耗费一定的时间。
如果没有之前说到的EDT的概念,那么你可能会这么做:

importBtn.addActionListener(new ActionListener() {
           @Override
            public void actionPerformed(ActionEvent e) {
                try{
                   lb.setText("1.检查数据合法性...");
                   Thread.sleep(3000);//模仿检测数据合法性
                   lb.setText("2.正在导入数据...");
                   Thread.sleep(4000);//模仿导入数据
                   lb.setText("3.导入成功!");
                }catch (InterruptedException e1) {
                   e1.printStackTrace();
                }
            }
        });

但是,如果运行一下的话,会发现现象是这样:点击按钮,界面卡住,按钮变得不可触发,直到一段时间(7秒)之后界面显示“3.导入成功”。期间并没有显示“1.检查数据合法性”和“2.正在导入数据”。
这个现象印证了上面说的理论:当事件派发线程中正在执行的事件监听函数执行完毕,才能进行UI组件的刷新操作,并且派发事件队列中的下一个。

下面是修改后的代码,将耗时的操作放在一个新的工作线程中执行:

importBtn.addActionListener(newActionListener() {
            @Override
            public voidactionPerformed(ActionEvent e) {
                new Thread(new Runnable() {//开辟一个工作线程
                    @Override
                    public void run() {
                        try {
                            lb.setText("1.检查数据合法性...");
                           Thread.sleep(3000);//模仿检测数据合法性
                            lb.setText("2.正在导入数据...");
                           Thread.sleep(4000);//模仿导入数据
                            lb.setText("3.导入成功!");
                        } catch(InterruptedException e1) {
                           e1.printStackTrace();
                        }
                    }
                }).start();
            }
        });

没有对比就没有伤害,以下是我两种方式导入数据案例。

主题

下面到了SwingUtilities的内容。在swing编程中有一个编程原则:所有的界面相关的更新,都应该在 EDT 上执行,否则会导致界面绘制出现不稳定性错误。这也就意味着上面代码的lb.setText("2.正在导入数据...");应该在EDT中,而非新的工作线程中执行。这样就出现了一个矛盾:耗时的操作必须要在工作线程中执行,否则会出现界面刷新不及时和卡顿的现象,而工作线程中的界面刷新代码又会导致界面绘制的不稳定。
SwingUtilities可以解决这个矛盾。SwingUtilities的invokeLater和invokeAndWait方法可以将一个可执行对象(Runnable)实例追加到EDT的可执行队列中。那么最后的代码应该是这样的:

importBtn.addActionListener(newActionListener() {
            @Override
            public voidactionPerformed(ActionEvent e) {
                new Thread(new Runnable() {
                    @Override
                    public void run() {
                        try {
                           SwingUtilities.invokeLater(new Runnable() {
                                @Override
                                public voidrun() {
                                    lb.setText("1.检查数据合法性...");
                                }
                            });
                           Thread.sleep(3000);//模仿检测数据合法性
                           SwingUtilities.invokeLater(new Runnable() {
                                @Override
                                public voidrun() {
                                   lb.setText("2.正在导入数据...");
                                }
                            });
                           Thread.sleep(4000);//模仿导入数据
                            SwingUtilities.invokeLater(newRunnable() {
                                @Override
                                public voidrun() {
                                   lb.setText("3.导入成功!");
                                }
                            });
                        } catch(InterruptedException e1) {
                           e1.printStackTrace();
                        }
                    }
                }).start();
            }
        });

金沙官网线上 1

结论

通过上面内容可以总结以下两个swing编程原则:
所有的界面相关的更新,都应该在 EDT 上执行
而耗时的后台运行,不应该在 EDT 上执行

运行 结果对比:

lambda表达式重写上面的代码

 importBtn.addActionListener(e -> {
            new Thread(() -> {
                try {
                   SwingUtilities.invokeLater(() -> lb.setText("1.检查数据合法性..."));
                    Thread.sleep(3000);//模仿检测数据合法性
                    SwingUtilities.invokeLater(()-> lb.setText("2.正在导入数据..."));
                    Thread.sleep(4000);//模仿导入数据
                   SwingUtilities.invokeLater(() -> lb.setText("3.导入成功!"));
                } catch (InterruptedExceptione1) {
                    e1.printStackTrace();
                }
            }).start();
        });

首先使用一般sql语句导入,因为时间原因,我就没有等待程序执行完,但是我记录了大约需要多少时间,以及执行了多少时间。
导入数据共计:258113条,执行了38秒,已经入库了6971条,大约还需要1429秒。(不去考虑电脑配置,界面数据加载耗时等因素)

金沙官网线上 2

接下来我们看看同样的数据量 SqlBulkCopy效果如何:

金沙官网线上 3

本文由金沙官网线上发布于编程,转载请注明出处:C金沙官网线上# SqlBulkCopy数据批量入库

您可能还会对下面的文章感兴趣: