shell腳本連接、讀寫(xiě)、操作mysql數(shù)據(jù)庫(kù)實(shí)例
本文介紹了如何在shell中讀寫(xiě)mysql數(shù)據(jù)庫(kù)。主要介紹了如何在shell 中連接mysql數(shù)據(jù)庫(kù),如何在shell中創(chuàng)建數(shù)據(jù)庫(kù),創(chuàng)建表,插入csv文件,讀取mysql數(shù)據(jù)庫(kù),導(dǎo)出mysql數(shù)據(jù)庫(kù)為xml或html文件, 并分析了核心語(yǔ)句。本文介紹的方法適用于PostgreSQL ,相對(duì)mysql而言,shell 中讀寫(xiě)PostgreSQL會(huì)更簡(jiǎn)單些。
1. 連接mysql 數(shù)據(jù)庫(kù)
shell中連接數(shù)據(jù)庫(kù)的方法很簡(jiǎn)單,只需要指定用戶(hù)名,密碼,連接的數(shù)據(jù)庫(kù)名稱(chēng),然后通過(guò)重定向,輸入mysql的語(yǔ)句,如下所示:
show databases;
EOF
但這并不是一個(gè)好辦法,任何使用該腳本的用戶(hù)都能看到該數(shù)據(jù)庫(kù)用戶(hù)的賬號(hào)和密碼,要解決這個(gè)問(wèn)題,可以用mysql 數(shù)據(jù)庫(kù)的一個(gè)特殊配置文件。mysql 數(shù)據(jù)庫(kù)使用$HOME/.my.cnf 文件來(lái)讀取特殊的啟動(dòng)命令和設(shè)置。其中一項(xiàng)設(shè)置是由該用戶(hù)賬戶(hù)發(fā)起的mysql 會(huì)話(huà)的默認(rèn)密碼。要在這個(gè)文件中設(shè)置默認(rèn)密碼,可以加入下面的內(nèi)容:
[client]
password = 123456
然后,別忘了修改權(quán)限:
chmod 400 .my.cnf
這樣就可以通過(guò)腳本訪(fǎng)問(wèn)mysql數(shù)據(jù)庫(kù)了,如下所示:
#!/bin/bash
MYSQL=`which mysql`
$MYSQL test -u root << EOF
show databases;
show tables;
select * from employees where salary > 4000;
EOF
2. 創(chuàng)建數(shù)據(jù)庫(kù)
通過(guò)上面的方法連接數(shù)據(jù)庫(kù),再通過(guò)重定向輸入mysql語(yǔ)句,shell中讀寫(xiě)mysql基本就介紹完了。只要把sql語(yǔ)句寫(xiě)對(duì)了,通過(guò)重定向執(zhí)行即可,下面來(lái)看一個(gè)實(shí)例:
#!/bin/bash
##############################
# @file create_db_mysql.sh
# @brief create database and tables in mysql
# @author Mingxing LAI
# @version 0.1
# @date 2013-01-20
##############################
USER="root"
DATABASE="students"
TABLE="students"
######################
#crate database
mysql -u $USER << EOF 2>/dev/null
CREATE DATABASE $DATABASE
EOF
[ $? -eq 0 ] && echo "created DB" || echo DB already exists
######################
#create table
mysql -u $USER $DATABASE << EOF 2>/dev/null
CREATE TABLE $TABLE(
id int,
name varchar(100),
mark int,
dept varchar(4)
);
EOF
[ $? -eq 0 ] && echo "Created table students" || echo "Table students already exist"
######################
#delete data
mysql -u $USER $DATABASE << EOF 2>/dev/null
DELETE FROM $TABLE;
EOF
這個(gè)腳本比較簡(jiǎn)單,就是幾條SQL語(yǔ)句,沒(méi)什么好解釋的,下面來(lái)看一下,如何讀入csv 文件,然后插入到mysql數(shù)據(jù)庫(kù)中。
3. 插入csv 文件
上面創(chuàng)建了一個(gè)學(xué)生表,表中有學(xué)生的學(xué)號(hào),姓名,成績(jī),系別,假設(shè)有一個(gè)csv文件,內(nèi)容如下:
1,Navin M,98,CS
2,Kavya N,70,CS
3,Nawaz O,80,CS
4,Hari S,80,EC
5,Alex M,50,EC
6,Neenu J,70,EC
7,Bob A,30,EC
8,Anu M,90,AE
9,Sruthi,89,AE
10,Andrew,89,AE
為了將csv 文件插入到數(shù)據(jù)庫(kù),我們需要逐行讀入,然后給字符串加上雙引號(hào),最后生成語(yǔ)句如下:
insert into students VALUES(1, "Navin M", 98, "CS");
要解析csv 文件,最好的工具莫過(guò)于awk了,將域的分隔符指定為逗號(hào)-F,,awk就自動(dòng)將各個(gè)域拆分出來(lái)了,然后在需要雙引號(hào)的地方打印輸出一個(gè)雙引號(hào),就能夠輕松得到下面這樣的數(shù)據(jù):
query=`echo $line | awk -F, '{ printf("%s,\"%s\",%s,\"%s\"", $1, $2, $3, $4)}'`
statement=`echo "INSERT INTO $TABLE VALUES($query);"`
echo $statement
當(dāng)然了,你也可以用其他辦法,不過(guò),幾乎沒(méi)有比awk更簡(jiǎn)單的了,第2種方法如下:
oldIFS=$IFS
IFS=,
values=($line)
values[1]="\"`echo ${values[1]} | tr ' ' '#' `\""
values[3]="\"`echo ${values[3]}`\""
query=`echo ${values[@]} | tr ' #' ', '`
IFS=$oldIFS
statement=`echo "INSERT INTO $TABLE VALUES($query);"`
echo "$statement"
首先通過(guò)指定域分隔符,將csv文件解析成一個(gè)數(shù)組,然后將空格替換成一個(gè)特殊的符號(hào)"#"(因?yàn)楹竺娴奶鎿Q中,會(huì)一次性輸出數(shù)組,而數(shù)組是用空格分隔各字段,我們要將分隔數(shù)組的空格替換成逗號(hào),所以這里將數(shù)據(jù)中的空格替換成"#") ,給字符串加上雙引號(hào),最后再把空格替換成逗號(hào),把"#"替換為空格。這種方法真是讓人抓狂,我第一次就沒(méi)有看明白,尤其是為什么要將空格替換成"#"。
完整的插入數(shù)據(jù)的程序如下:
#!/bin/bash
#
# @file write_to_db_mysql.sh
# @brief wirte data to database in mysql
# @author Mingxing LAI
# @version 0.1
# @date 2013-01-20
#
USER="root"
DATABASE="students"
TABLE="students"
if [ $# -ne 1 ]; then
echo $0 DATAFILE
echo
exit 2
fi
data=$1
while read line;
do
# query=`echo $line | awk -F, '{ printf("%s,\"%s\",%s,\"%s\"", $1, $2, $3, $4)}'`
oldIFS=$IFS
IFS=,
values=($line)
values[1]="\"`echo ${values[1]} | tr ' ' '#' `\""
values[3]="\"`echo ${values[3]}`\""
query=`echo ${values[@]} | tr ' #' ', '`
IFS=$oldIFS
statement=`echo "INSERT INTO $TABLE VALUES($query);"`
# echo $statement
mysql -u $USER $DATABASE << EOF
INSERT INTO $TABLE VALUES($query);
EOF
done < $data
if [[ $? -eq 0 ]]; then
echo "Wrote data into DB"
fi
4. 讀取數(shù)據(jù)
知道怎么在shell 中連接mysql ,也知道了怎么在shell中批量執(zhí)行sql 語(yǔ)句,讀取數(shù)據(jù),就沒(méi)有任何難度了。
#
# @file read_db_mysql.sh
# @brief read data from mysql
# @author Mingxing LAI
# @version 0.1
# @date 2013-01-20
#
USER="root"
DATABASE="students"
TABLE="students"
#用tail 去掉表頭
depts=`mysql -u $USER $DATABASE <<EOF | tail -n +2
SELECT DISTINCT dept FROM $TABLE;
EOF`
for d in $depts; do
echo Department: $d
result="`mysql -u $USER $DATABASE << EOF
set @i:=0;
SELECT @i:=@i+1 as rank, name, mark FROM students WHERE dept="$d" ORDER BY mark DESC;
EOF`"
echo "$result"
echo
done
我們還可以在mysql語(yǔ)句中,使用選項(xiàng)來(lái)控制數(shù)據(jù)的輸出格式
-H 輸出為html
-X 輸出為xml
如下所示:
#!/bin/bash
USER="root"
DATABASE="students"
TABLE="students"
mysql -u $USER $DATABASE -H << EOF
select * from $TABLE
EOF
html 格式的可讀性比較差,輸出效果如下:
可讀性差也可以理解,因?yàn)槿思矣X(jué)得,你沒(méi)必要修改么,直接以html形式展示數(shù)據(jù)就可以了。
1 Navin M 98 CS
2 Kavya N 70 CS
3 Nawaz O 80 CS
4 Hari S 80 EC
5 Alex M 50 EC
6 Neenu J 70 EC
7 Bob A 30 EC
8 Anu M 90 AE
9 Sruthi 89 AE
10 Andrew 89 AE
xml形式的數(shù)據(jù)顯示就比較正常了,直接將上面的-H 換成-X,輸出如下:
<resultset statement="select * from students" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<row>
<field name="id">1</field>
<field name="name">Navin M</field>
<field name="mark">98</field>
<field name="dept">CS</field>
</row>
<row>
<field name="id">2</field>
<field name="name"> Kavya N</field>
<field name="mark">70</field>
<field name="dept">CS</field>
</row>
</resultset>
完。
相關(guān)文章
Linux Shell 自動(dòng)交互功能實(shí)現(xiàn)
本文主要介紹了Linux Shell 自動(dòng)交互功能實(shí)現(xiàn),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-08-08shell腳本正則匹配文件中的Email并寫(xiě)入到文件中代碼分享
有時(shí)我們會(huì)處理日志文件,或其他文本文件,并將里面含有的Email讀取出來(lái),可以利用shell處理文件的方法來(lái)讀取2014-04-04每天學(xué)一個(gè) Linux 命令之more命令
more命令,功能類(lèi)似 cat ,more會(huì)以一頁(yè)一頁(yè)的顯示方便使用者逐頁(yè)閱讀,而最基本的指令就是按空白鍵(space)就往下一頁(yè)顯示,按 b 鍵就會(huì)往回(back)一頁(yè)顯示,而且還有搜尋字串的功能2016-12-12