MySQL中游標使用以及讀取文本數據

時間 2019-12-07

標籤 mysql 遊標使用以及讀取文本數據欄目 MySQL 简体版

原文原文鏈接

前言

以前一直沒有接觸數據庫的學習，只是本科時候修了一本數據庫基本知識的課。當時只對C++感興趣，天真的認爲其它的課都沒有用，數據庫也是半懂不懂，胡亂就考試過了。如今學習大數據分析，接觸了數據挖掘，才感受到數據庫是不可跨越的坎。直到如今才感受到《操做系統》、《編譯原理》、《計算機組成原理》等等課程的重要性。在浩瀚的知識面前，我的是很是眇小的。掌握了一種思想以後，任何事情都不困難，困難的是你是否真的靜下心看一看幫助文檔、認真的Google。靜心、靜氣、認真、執着。html

遊標-cursor

學習了幾天MySQL，談一談本身對遊標的認識。數據庫

遊標就相似於C++中的指針，用於指向查詢結果。好比你查詢後的的數據格式以下：函數

+------------+----------------------+------+------+------+-------------+----------+----------+------+---------+
| station_id | get_time             | PM25 | PM10 | NO2  | temperature | pressure | humidity | wind | weather |
+------------+----------------------+------+------+------+-------------+----------+----------+------+---------+
| 001001     | 2/8/2013 9:00:00 PM  |  149 |   59 |   16 |          -5 |     1031 |       46 |    4 |       1 |
| 001001     | 2/8/2013 10:00:00 PM |  159 |   65 |   22 |          -5 |     1030 |       46 |    1 |       1 |
| 001001     | 2/9/2013 12:00:00 AM |  179 |   73 |   28 |          -6 |     1029 |       46 |    4 |       1 |
| 001001     | 2/9/2013 2:00:00 AM  |  194 |   73 |   29 |          -7 |     1028 |       49 |    3 |       1 |
| 001001     | 2/9/2013 3:00:00 AM  |  191 |   73 |   27 |          -7 |     1028 |       50 |    2 |       1 |
| 001001     | 2/9/2013 4:00:00 AM  |  194 |   73 |   25 |          -7 |     1026 |       53 |    2 |       1 |
| 001001     | 2/9/2013 5:00:00 AM  |  193 |   73 |   23 |          -7 |     1026 |       54 |    2 |       1 |
| 001001     | 2/9/2013 6:00:00 AM  |  192 |   73 |   21 |          -8 |     1026 |       52 |    2 |       1 |
| 001001     | 2/9/2013 7:00:00 AM  |  192 |   73 |   23 |          -8 |     1025 |       54 |    3 |       1 |
| 001001     | 2/9/2013 8:00:00 AM  |  190 |   73 |   20 |          -8 |     1025 |       55 |    3 |       1 |
+------------+----------------------+------+------+------+-------------+----------+----------+------+---------+

你若是想逐條處理數據，那麼必需要用到遊標進行循環處理。oop

加載進來的數據是varchar格式，可是對於第二個屬性「get_time」咱們須要的格式是「datatime」，須要進行獲取屬性值並進行循環處理。學習

使用遊標的步驟以下：fetch

1.定義遊標 declare 遊標名 cursor for select語句大數據

2.定義處理遊標結束的變量 declare continue handler for not found set 變量名= true;spa

3.打開遊標 open 遊標名操作系統

4.判斷是否結束，若是不結束，則處理當前遊標指向值；若是結束，則結束循環設計

5.關閉遊標 close 遊標名

注：遊標通常是在存儲過程（procedure）中調用，procedure相似於C++中的函數，裏面封裝了SQL語句，想要使用時，直接CALL ‘procedure_name’便可。遊標（cursor）中如有使用的變量必須在聲明cursor前把變量定義完。詳細的代碼設計以下：

CREATE DEFINER=`root`@`localhost` PROCEDURE `strToDate`()
begin
 
 -- 定義一個臨時變量用於存儲轉換後的時間格式
declare temp datetime;

 -- 定義字符串臨時變量，存儲查詢後的每條內容
declare str varchar(150);

 -- 是否結束的標識
declare flag int default false;

 -- 定義遊標
declare getTimeCursor cursor for select get_time from train;

 -- 定義結束的標識
declare continue handler for not found  set flag = true;

 -- 打開遊標
open getTimeCursor;

 -- 開始循環處理
 read_loop:loop
 
 -- 把當前遊標內容放到變量中
fetch getTimeCursor into str;

 -- 若是結束標識爲TRUE，則結束循環
if flag then
leave read_loop;
end if;

 -- 不然循環處理每一個屬性，調用字符串轉換日期函數
set temp = (select str_to_date(str,'%c/%e/%Y %l:%i:%s %p'));

 -- 把轉換結果存儲到新的表中insert into time_test values(temp);

 -- 結束循環
end loop;

 -- 關閉遊標
close getTimeCursor;

 -- 查詢結果
select * from time_test limit 10;
end

其中，str_to_date()函數的功能是把string類型的數據轉成date類型。查詢後的結果爲：

+---------------------+
| get_time            |
+---------------------+
| 2013-02-09 16:00:00 |
| 2013-02-08 21:00:00 |
| 2013-02-08 22:00:00 |
| 2013-02-09 00:00:00 |
| 2013-02-09 02:00:00 |
| 2013-02-09 03:00:00 |
| 2013-02-09 04:00:00 |
| 2013-02-09 05:00:00 |
| 2013-02-09 06:00:00 |
| 2013-02-09 07:00:00 |
+---------------------+

see，全部字符串都轉換成了標準的時間格式。

MySQL load data控制

其實上面的問題徹底能夠利用另一種方法完成，那就是在裝載數據的時候進行格式控制。具體SQL代碼以下：

use train;
drop table traindata;
create table if not exists traindata(
id int auto_increment primary key,
station_id varchar(10),
get_time datetime,
PM25 int,
PM10 int,
NO2 int,
temperature int,
pressure int,
humidity int,
wind double,
weather int);

load data local
infile 'f:\\dataset\\beijing\\crawleddata.txt'
into table traindata
fields terminated by ','
(station_id, @var_time, PM25, PM10, NO2, temperature, pressure, humidity, wind, weather)
set get_time = str_to_date(@var_time, '%c/%e/%Y %l:%i:%s %p');

select * from traindata limit 10;

加載進數據庫後，具體數據格式以下：

+----+------------+---------------------+------+------+------+-------------+----------+----------+------+---------+
| id | station_id | get_time            | PM25 | PM10 | NO2  | temperature | pressure | humidity | wind | weather |
+----+------------+---------------------+------+------+------+-------------+----------+----------+------+---------+
|  1 |       1001 | 2013-02-08 21:00:00 |  149 |   59 |   16 |          -5 |     1031 |       46 |    4 |       1 |
|  2 |       1001 | 2013-02-08 22:00:00 |  159 |   65 |   22 |          -5 |     1030 |       46 |    1 |       1 |
|  3 |       1001 | 2013-02-09 00:00:00 |  179 |   73 |   28 |          -6 |     1029 |       46 |    4 |       1 |
|  4 |       1001 | 2013-02-09 02:00:00 |  194 |   73 |   29 |          -7 |     1028 |       49 |    3 |       1 |
|  5 |       1001 | 2013-02-09 03:00:00 |  191 |   73 |   27 |          -7 |     1028 |       50 |    2 |       1 |
|  6 |       1001 | 2013-02-09 04:00:00 |  194 |   73 |   25 |          -7 |     1026 |       53 |    2 |       1 |
|  7 |       1001 | 2013-02-09 05:00:00 |  193 |   73 |   23 |          -7 |     1026 |       54 |    2 |       1 |
|  8 |       1001 | 2013-02-09 06:00:00 |  192 |   73 |   21 |          -8 |     1026 |       52 |    2 |       1 |
|  9 |       1001 | 2013-02-09 07:00:00 |  192 |   73 |   23 |          -8 |     1025 |       54 |    3 |       1 |
| 10 |       1001 | 2013-02-09 08:00:00 |  190 |   73 |   20 |          -8 |     1025 |       55 |    3 |       1 |
+----+------------+---------------------+------+------+------+-------------+----------+----------+------+---------+