2. 程式人生 > >Elasticsearch JDBC的使用-MySQL 資料來源匯入和增量索引、更新

Elasticsearch JDBC的使用-MySQL 資料來源匯入和增量索引、更新

阿新 • • 發佈：2019-02-07

在使用 Elasticsearch 的時候，經常會涉及到要將其它資料來源的資料匯入到 Elasticsearch 中，今天就來介紹一下關於 Elasticsearch 從 MySQL 匯入資料和增量索引的實現
這裡要用到一個 Elasticsearch 的外掛 elasticsearch-jdbc

需要的資源和版本
Elasticsearch 版本：2.2.0 CSDN下載
elasticsearch-jdbc 版本 ： 2.2 CSDN下載

一、安裝 jdbc

jdbc 的壓縮包我已經放在了 /usr/local/src/ 目錄下，可以去它的 GitHub地址 獲取對應版本的壓縮包

cd /usr/local
 
/src/
unzip ./elasticsearch-jdbc-2.2.0.0-dist.zip
cp -r ./elasticsearch-jdbc-2.2.0.0 /usr/local/elasticsearch-2.2.0/jdbc2.2

這樣就可以使用啦，jdbc 還提供了一些常用的例子，在 【ES安裝目錄/jdbc2.2/bin/ 】這個資料夾下，改一改就可以用，都是bash 檔案，記得加執行許可權哦

二、使用jdbc

我們先在 MySQL中建立一個用於測試的資料表 article ，並新增幾條資料
（注意， update_time 欄位我加了ON UPDATE CURRENT_TIMESTAMP，資料發生改變就會更新此欄位）

DROP TABLE IF EXISTS `article`;
CREATE TABLE `article` (
  `id` mediumint(8) unsigned NOT NULL AUTO_INCREMENT,
  `subject` varchar(150) NOT NULL,
  `author` varchar(15) DEFAULT NULL,
  `create_time` timestamp NULL DEFAULT NULL,
  `update_time` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP
 
,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8;
# 資料
INSERT INTO `article` VALUES ('1', '＂閨蜜＂崔順實被韓檢方傳喚 韓總統府促徹查真相', 'jam', '2016-10-31 17:49:21', '2016-10-31 17:50:21');
INSERT INTO `article` VALUES ('2', '韓舉行＂護國訓練＂ 青瓦臺:決不許國家安全出問題', 'jam00', '2016-10-31 17:50:39', '2016-10-31 17:50:51');
INSERT INTO `article` VALUES ('3', '媒體稱FBI已經取得搜查令 檢視希拉里電郵', 'tomi', '2016-10-31 17:51:03', '2016-10-31 17:51:08');
INSERT INTO `article` VALUES ('4', '村上春樹獲安徒生獎 演講中談及歐洲排外問題', 'jason', '2016-10-31 17:51:38', '2016-10-31 17:51:41');
INSERT INTO `article` VALUES ('5', '希拉里團隊炮轟FBI 參院民主黨領袖批其“違法”', 'tommy', '2016-10-31 17:52:07', '2016-10-31 17:52:09');

1、資料來源匯入

首先執行全部資料匯入（注：ES 使用的是預設配置）
我們寫一個名叫 mysql-article.sh 的bash指令碼，並放在 /usr/local/elasticsearch-2.2.0/jdbc2.2/bin/mysql-article.sh 下面，指令碼內容如下（內容註釋會在後面給出）

#執行
/usr/local/elasticsearch-2.2.0/jdbc2.2/bin/mysql-article.sh 
#檔案內容如下
#!/bin/sh
DIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" && pwd )"
bin=${DIR}/../bin
lib=${DIR}/../lib

echo '
{
    "type" : "jdbc",
    "jdbc" : {
        "url" : "jdbc:mysql://localhost:3306/test",
        "user" : "root",
        "password" : "123456",
        "sql" : "select *, id as _id from article",
        "index" : "jdbctest",
        "type" : "article",
        "index_settings" : {
            "analysis" : {
                "analyzer" : {
                    "ik" : {
                        "tokenizer" : "ik"
                    }
                }
            }
        },
        "type_mapping": {
            "article" : {
                "properties" : {
                    "id" : {
                        "type" : "integer",
                        "index" : "not_analyzed"
                    },
                    "subject" : {
                        "type" : "string",
                        "analyzer" : "ik"
                    },
                    "author" : {
                        "type" : "string",
                        "analyzer" : "ik"
                    },
                    "create_time" : {
                        "type" : "date"
                    },
                    "update_time" : {
                        "type" : "date"
                    }
                }
            }
        }
    }
}
' | java \
    -cp "${lib}/*" \
    -Dlog4j.configurationFile=${bin}/log4j2.xml \
    org.xbib.tools.Runner \
    org.xbib.tools.JDBCImporter

執行後會自動建立 jdbctest 索引（若不存在） ，article 型別 和幾個對應的欄位，這裡因為有中文，我使用了 ik 分詞器（如何使用？）
若執行失敗，請檢視日誌檔案，jdbc 的日誌存放在 /usr/local/elasticsearch-2.2.0/logs/jdbc.log
檢視是否匯入成功

curl -XGET 'http://localhost:9200/jdbctest/article/_search?pretty'
#返回
{
  "took" : 33,
  "timed_out" : false,
  "_shards" : {
    "total" : 5,
    "successful" : 5,
    "failed" : 0
  },
  "hits" : {
    "total" : 5,
    "max_score" : 1.0,
    "hits" : [ {
      "_index" : "jdbctest",
      "_type" : "article",
      "_id" : "5",
      "_score" : 1.0,
      "_source" : {
        "id" : 5,
        "subject" : "希拉里團隊炮轟FBI 參院民主黨領袖批其“違法”",
        "author" : "tommy",
        "create_time" : "2016-10-31T17:52:07.000+08:00",
        "update_time" : "2016-10-31T17:52:09.000+08:00"
      }
    }, {
      "_index" : "jdbctest",
      "_type" : "article",
      "_id" : "2",
      "_score" : 1.0,
      "_source" : {
        "id" : 2,
        "subject" : "韓舉行＂護國訓練＂ 青瓦臺:決不許國家安全出問題",
        "author" : "jam00",
        "create_time" : "2016-10-31T17:50:39.000+08:00",
        "update_time" : "2016-10-31T17:50:51.000+08:00"
      }
    }, {
      "_index" : "jdbctest",
      "_type" : "article",
      "_id" : "4",
      "_score" : 1.0,
      "_source" : {
        "id" : 4,
        "subject" : "村上春樹獲安徒生獎 演講中談及歐洲排外問題",
        "author" : "jason",
        "create_time" : "2016-10-31T17:51:38.000+08:00",
        "update_time" : "2016-10-31T17:51:41.000+08:00"
      }
    }, {
      "_index" : "jdbctest",
      "_type" : "article",
      "_id" : "1",
      "_score" : 1.0,
      "_source" : {
        "id" : 1,
        "subject" : "＂閨蜜＂崔順實被韓檢方傳喚 韓總統府促徹查真相",
        "author" : "jam",
        "create_time" : "2016-10-31T17:49:21.000+08:00",
        "update_time" : "2016-10-31T17:50:21.000+08:00"
      }
    }, {
      "_index" : "jdbctest",
      "_type" : "article",
      "_id" : "3",
      "_score" : 1.0,
      "_source" : {
        "id" : 3,
        "subject" : "媒體稱FBI已經取得搜查令 檢視希拉里電郵",
        "author" : "tomi",
        "create_time" : "2016-10-31T17:51:03.000+08:00",
        "update_time" : "2016-10-31T17:51:08.000+08:00"
      }
    } ]
  }
}

內容已成功匯入到 Elasticsearch 中

2、增量索引、更新

如果我們對資料做了更改或是有新資料加入，若再執行全部匯入，就有點得不償失了
這裡我們就要用到jdbc 的兩個屬性 statefile（狀態檔案） 和 schedule（計劃任務時間），並且 sql 語句也要改成動態的
改動如下

"statefile" : "statefile-article.json",
"schedule" : "0 0-59 0-23 ? * *",
"sql" : [
    {
        "statement" : "select *, id as _id from article where update_time > ?",
        "parameter" : [ "$metrics.lastexecutionstart" ]
    }
],

改動後的完整檔案 mysql-article.sh

#!/bin/sh
DIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" && pwd )"
bin=${DIR}/../bin
lib=${DIR}/../lib

echo '
{
    "type" : "jdbc",
    "jdbc" : {
        "url" : "jdbc:mysql://localhost:3306/test",
        "user" : "root",
        "password" : "123456",
        "statefile" : "statefile-article.json",
        "schedule" : "0 0-59 0-23 ? * *",
        "sql" : [
            {
                "statement" : "select *, id as _id from article where update_time > ?",
                "parameter" : [ "$metrics.lastexecutionstart" ]
            }
        ],
        "index" : "jdbctest",
        "type" : "article",
        "index_settings" : {
            "analysis" : {
            "analyzer" : {
                "ik" : {
                    "tokenizer" : "ik"
                }
            }
        }
        },
        "type_mapping": {
            "article" : {
                "properties" : {
                    "id" : {
                        "type" : "integer",
                        "index" : "not_analyzed"
                    },
                    "subject" : {
                        "type" : "string",
                        "analyzer" : "ik"
                    },
                    "author" : {
                        "type" : "string",
                        "analyzer" : "ik"
                    },
                    "create_time" : {
                        "type" : "date"
                    },
                    "update_time" : {
                        "type" : "date"
                    }
                }
            }
        }
    }
}
' | java \
    -cp "${lib}/*" \
    -Dlog4j.configurationFile=${bin}/log4j2.xml \
    org.xbib.tools.Runner \
    org.xbib.tools.JDBCImporter

執行該檔案 ：/usr/local/elasticsearch-2.2.0/jdbc2.2/bin/mysql-article.sh
可以看到 命令列端 被佔用，一直在執行，並且在 mysql-article.sh 的同級目錄下生成了一個 statefile-article.json 的檔案，sql 語句中需要的資料 lastexecutionstart 就儲存在該檔案中
現在我們來改動一下MySQL 中的資料，增加一條資料，並修改一條 id 等於 5 的資料

INSERT INTO article() VALUES(NULL,'測試JDBC','jam00','2016-11-01 13:34:15','2016-11-01 13:34:15');
UPDATE article SET `subject`='測試JDBC-改動' WHERE id=5;

最多等一分鐘，再看看ES 中的資料

curl -XGET 'http://localhost:9200/jdbctest/article/_search?pretty' -d '{
    "sort": { 
        "id": { "order": "desc" }
    }
}'
# 返回 
...
"hits" : [ {
      "_index" : "jdbctest",
      "_type" : "article",
      "_id" : "6",
      "_score" : null,
      "_source" : {
        "id" : 6,
        "subject" : "測試JDBC",
        "author" : "jam00",
        "create_time" : "2016-11-01T13:34:15.000+08:00",
        "update_time" : "2016-11-01T13:34:15.000+08:00"
      },
      "sort" : [ 6 ]
    }, {
      "_index" : "jdbctest",
      "_type" : "article",
      "_id" : "5",
      "_score" : null,
      "_source" : {
        "id" : 5,
        "subject" : "測試JDBC-改動",
        "author" : "tommy",
        "create_time" : "2016-10-31T17:52:07.000+08:00",
        "update_time" : "2016-11-01T13:35:41.000+08:00"
      },
      "sort" : [ 5 ]
    }
...

測試成功。
為了讓 mysql-article.sh 後臺執行，我們可以使用 nohup 命令

nohup /usr/local/elasticsearch-2.2.0/jdbc2.2/bin/mysql-article.sh &

當我們想停止執行的時候。

ps aux |grep jdbc2.2
#返回
root     26118  0.0  0.1 106092  1212 pts/0    S    14:03   0:00 /bin/sh /usr/local/elasticsearch-2.2.0/jdbc2.2/bin/mysql-article.sh
root     26123 11.0  4.4 1079192 44932 pts/0   Sl   14:03   0:00 java -cp /usr/local/elasticsearch-2.2.0/jdbc2.2/bin/../lib/* -Dlog4j.configurationFile=/usr/local/elasticsearch-2.2.0/jdbc2.2/bin/../bin/log4j2.xml org.xbib.tools.Runner org.xbib.tools.JDBCImporter

# 使用 kill 命令關閉程序， 26123 就是上面一句返回的程序號，不用殺掉 26118 ，殺掉26123 這個程序，26118 程序會自動關閉
kill -9 26123

至此，MySQL 資料來源的 增量索引和更新就完成了。

3、bash 檔案釋義

增量索引的bash檔案註釋如下，更多詳細配置請查閱官方文件

#!/bin/sh
# 當前指令碼的絕對路徑
DIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" && pwd )"
bin=${DIR}/../bin
lib=${DIR}/../lib

echo '
{
    "type" : "jdbc",
    "jdbc" : {
        # 連結 mysql 的 test 資料庫
        "url" : "jdbc:mysql://localhost:3306/test",
        # mysql 使用者
        "user" : "root",
        # mysql 密碼
        "password" : "123456",
        # 計劃任務狀態檔案
        "statefile" : "statefile-article.json",
        # 計劃任務時間 這裡是每分鐘執行一次
        "schedule" : "0 0-59 0-23 ? * *",
        # 執行匯入的sql 語句
        "sql" : [
            {
                "statement" : "select *, id as _id from article where update_time > ?",
                "parameter" : [ "$metrics.lastexecutionstart" ]
            }
        ],
        # 索引名稱 jdbctest
        "index" : "jdbctest",
        # 型別名稱 article
        "type" : "article",
        # 型別設定
        "index_settings" : {
            "analysis" : {
            "analyzer" : {
                "ik" : {
                        # 涉及到中文使用ik 分詞
                    "tokenizer" : "ik"
                }
            }
        }
        },
        # 型別中的欄位對映
        "type_mapping": {
            # 型別名稱
            "article" : {
                "properties" : {
                    # 對應的欄位
                    "id" : {
                        # 欄位型別
                        "type" : "integer",
                        # 當成一個準確的值進行索引(全匹配)
                        "index" : "not_analyzed"
                    },
                    "subject" : {
                        "type" : "string",
                        "analyzer" : "ik"
                    },
                    "author" : {
                        "type" : "string",
                        "analyzer" : "ik"
                    },
                    "create_time" : {
                        "type" : "date"
                    },
                    "update_time" : {
                        "type" : "date"
                    }
                }
            }
        }
    }
}
' | java \
    -cp "${lib}/*" \
    -Dlog4j.configurationFile=${bin}/log4j2.xml \
    org.xbib.tools.Runner \
    org.xbib.tools.JDBCImporter

這裡選幾個屬性來介紹一下
url：資料庫連結串，所以把這個連結串改成其它資料來源，這個指令碼也可以使用（前提是那個資料來源中有對應的 article 表）
statefile ：計劃任務狀態檔名稱。它長這樣：

{
  "type" : "jdbc",
  "jdbc" : {
    "index_settings" : {
      "analysis" : {
        "analyzer" : {
          "ik" : {
            "tokenizer" : "ik"
          }
        }
      }
    },
    "index" : "jdbctest",
    "schedule" : "0 0-59 0-23 ? * *",
    "sql" : [ {
      "statement" : "select *, id as _id from article where update_time > ?",
      "parameter" : [ "$metrics.lastexecutionstart" ]
    } ],
    "metrics" : {
      "lastexecutionend" : "2016-11-01T06:01:01.441Z",
      "lastexecutionstart" : "2016-11-01T06:01:01.125Z",
      "counter" : "23"
    },
    "type" : "article",
    "statefile" : "statefile-article.json",
    "user" : "root",
    "password" : "123456",
    "url" : "jdbc:mysql://localhost:3306/test",
    "type_mapping" : {
      "article" : {
        "properties" : {
          "create_time" : {
            "type" : "date"
          },
          "id" : {
            "type" : "integer",
            "index" : "not_analyzed"
          },
          "author" : {
            "type" : "string",
            "analyzer" : "ik"
          },
          "update_time" : {
            "type" : "date"
          },
          "subject" : {
            "type" : "string",
            "analyzer" : "ik"
          }
        }
      }
    }
  }
}

其實 jdbc 每次執行的就是這個檔案，執行完成後就覆蓋此檔案，改變的只是 metrics 屬性內的時間，而 lastexecutionstart 這個時間就是我們下面 sql 語句要用到的最後更新時間
schedule ： 計劃任務時間表。表示多久執行一次更新。下面有幾個例子
0 0-59 0-23 ? * *：每分鐘執行一次
0 0/5 0-23 ? * * ：每五分鐘執行一次；當分鐘等於 0，5，10，15…55的時候執行
我還是貼一個官方的欄位描述

欄位名稱 允許的值 允許的特殊字元
Seconds 0-59 , - * /
Minutes 0-59 , - * /
Hours 0-23 , - * /
Day-of-month 1-31 , - * ? / L W
Month 1-12 or JAN-DEC , - * /
Day-of-Week 1-7 or SUN-SAT , - * ? / L #
Year (Optional) empty, 1970-2199 , - * /

詳細註釋請點選檢視

sql：支援兩種方式，一種是直接寫sql語句，一種是有條件的sql語句。一般我們會在sql語句中使用”field as _id “這樣的方式來指定這條資料在ES 中的唯一標識（field欄位為唯一標識）
parameter 屬性中的可選的動態引數有

$now - the current timestamp
$state - the state, one of: BEFORE_FETCH, FETCH, AFTER_FETCH, IDLE, EXCEPTION
$metrics.counter - a counter
$lastrowcount - number of rows from last statement
$lastexceptiondate - SQL timestamp of last exception
$lastexception - full stack trace of last exception
$metrics.lastexecutionstart - SQL timestamp of the time when last execution started
$metrics.lastexecutionend - SQL timestamp of the time when last execution ended
$metrics.totalrows - total number of rows fetched
$metrics.totalbytes - total number of bytes fetched
$metrics.failed - total number of failed SQL executions
$metrics.succeeded - total number of succeeded SQL executions

在上面例子中的 sql

select *, id as _id from article where update_time > ?

表示獲取更新時間（update_time）大於 最後執行時間（$metrics.lastexecutionstart）的所有資料

其它如 index、type_mapping 之類的屬性就不一一介紹了，很容易理解

趕快動手試一下吧！

相關推薦

Elasticsearch JDBC的使用-MySQL 資料來源匯入和增量索引、更新

在使用 Elasticsearch 的時候，經常會涉及到要將其它資料來源的資料匯入到 Elasticsearch 中，今天就來介紹一下關於 Elasticsearch 從 MySQL 匯入資料和增量索引的實現 這裡要用到一個 Elasticsearch 的外掛

ElasticSearch-jdbc從Mysql資料庫匯入和更新資料

環境： 需要的資源和版本： - git客戶端 - Elasticsearch 版本 2.2.0 安裝教程 - elasticsearch-jdbc 版本 2.2 - ik分詞器 版本 1.8 （下載後解壓將ik資料夾放在elastics

elasticsearch（一）java 分別使用同步和非同步方法進行索引、更新操作

一、索引或更新基本步驟 1) 建立與elasticsearch服務進行連線的RestHighLevelClient物件 RestHighLevelClient client = new RestHighLevelClient( Res

如何在MySQL中匯入和匯出資料庫並重置root密碼

英文原作者：Etel Sverdlov  翻譯&轉載來源：https://www.digitalocean.com/community/tutorials/how-to-import-and-export-databases-and-reset-a-root-password-in

sphinx 不關閉程序更新索引 和增量索引

更新單個at_resource 索引  /usr/local/sphinx211/bin/indexer -c /usr/local/sphinx211/etc/sphinx.conf at_resource --rotate 更新全部索引 /usr/local/sphin

JDBC-MYSQL-儲存函式和儲存過程的呼叫

最近要學習資料庫，在用JDBC呼叫儲存過程和儲存函式是出現了小麻煩。在MYSQL中，用JDBC呼叫儲存過程和儲存函式還是有一些不同的。  一，用JDBC呼叫儲存過程一般過程如下： String sql = "call proc(?,?)"; CallableSt

jdbc-mysql測試例子和原始碼詳解

目錄 簡介 什麼是JDBC 幾個重要的類 使用中的注意事項 使用例子 需求 工程環境 主要步驟 建立表 建立專案 引入依賴 編寫jdbc.prperties 獲得Connection物件 使用Connection物件完成儲存操作 原始碼分析 驅動註冊 DriverManager.register

mysql資料庫基礎(2）索引、主鍵、複合主鍵、外來鍵

增、刪、改、查 加“”表示為普通字元 mysql> insert into  t9 values("NULL",21,"game,flim"); +++++++++++++++++++++++++++++++ 新增新欄位 mysql> alter table  t4

面試知識點6：MySQL中InnoDB的一級索引、二級索引

每個InnoDB表具有一個特殊的索引稱為聚簇索引（也叫聚集索引，聚類索引，簇集索引）。如果表上定義有主鍵，該主鍵索引就是聚簇索引。如果未定義主鍵，MySQL取第一個唯一索引（unique）而且只含非空列（NOT NULL）作為主鍵，InnoDB使用它作為聚簇索引。如果沒有這樣

唯一索引和普通索引、資料分表

使用mysql 百萬級別資料量表結構大致如下：基礎表中欄位artifactId，每個值都不一樣。業務表字段artifactId可能會出現少量重複值。基礎表和業務表資料量均在百萬以上。兩個表中還有state欄位。state取值範圍0-4；最終狀態為4.現業務場景如下：有兩種查詢

mysql 匯出匯入資料庫以及函式、儲存過程

匯出函式： 用的最多的還是資料備份——全表匯出包括函式和儲存過程 1.單庫匯出 包括函式/檢視/儲存過程 mysqldump -hxxxx -uroot -pxxx -P3306 -R --default-character-set=utf8 hb > hb201

pymongo建立索引、更新、刪除

pymongo建立索引、更新、刪除     索引建立

JDBC增刪改查--資料庫增加刪除、更新、查詢例項

package cn.com.JDBC; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; pu

Elasticsearch使用Logstash-input-jdbc同步mysql資料（全量和增量）

作者：camelcanoe 來源：CSDN 原文：https://blog.csdn.net/camelcanoe/article/details/79759376 版權宣告：本文為博主原創文章，轉載請附上博文連結！ 專案中用到elasticsearch，初始化資料時時寫的程式從資

Elasticsearch使用Logstash-input-jdbc同步mysql資料（全量和增量）（windows）

專案中用到elasticsearch，初始化資料時時寫的程式從資料庫裡面查詢出來，然後多執行緒往elasticsearch裡面寫入的。今天試了一下Logstash-input-jdbc外掛，發現高效又方便，而且可以設定定時任務。1、安裝外掛在logstash的bin目錄下執行

mysql學習筆記（五）索引、檢視，匯入和匯出，備份和恢復

一、索引 索引是一種與表有關的結構，它的作用相當於書的目錄，可以根據目錄中的頁碼快速找到所需的內容。 當表中有大量記錄時，若要對錶進行查詢，沒有索引的情況是全表搜尋：將所有記錄一一取出，和查詢條件進行一一對比，然後返回滿足條件的記錄。這樣做會消耗大量資料庫系統時間，並造成大

mysql 全量備份和增量備份

mysql備份mysql 全量備份：vim /root/mysql_bakup.sh #!/bin/bash#Date:2017/5/2#Author:wangpengtai#Blog:http://wangpengtai.blog.51cto.com#At Sunday, we will backup th

solr5.5.4 增量索引 自動同步mysql數據

安裝 conf 結合 同步 移植 tom bin文件 部署應用程序 nbsp 前言：之前測試了solr好幾個版本都沒有成功，solr比較好下載的版本5.0，5.5，6.6。solr6.6結合tomcat8做自動同步mysql數據一直報錯，然後果斷測試5.5版本的，成功了。

使用SQL統計某個表每天的總量和增量 mysql數據庫

sql 總量 增量 統計 mysql舉例子：一個user表 有user_id自增主鍵，還有create_time用戶創建時間 業務需求 讓你統計每天用戶的總量和相比前一天增加了多少用戶量如圖表二這種。首先將每天的總量查出來 表中的時間一般為date_time類型 所以用個函數 SELECT D

jdbc-mysql基礎 ResultSetMetaData getColumnName getColumnLabel 得到列的名字和別名

price word 特點 編譯 輸出 cat 應用 ble ring 禮悟：　　 好好學習多思考，尊師重道存感恩。葉見尋根三二一，江河湖海同一體。 虛懷若谷良心主，願行無悔給最苦。讀書鍛煉強身心，誠勸且行且珍惜。 　　數據、數據，命根就在數