MySQL — 連接器 連接器的概念 它們往往是一類Python包，或者是一類已經寫好的Python庫。這些庫提供了我們Python去連接資料庫伺服器的基本功能。 既然它是一個包，那麼我們首先學會導入這個包 #! /usr/bin/env python3 # coding: utf-8 fr ...
MySQL — 連接器
連接器的概念
它們往往是一類Python包，或者是一類已經寫好的Python庫。這些庫提供了我們Python去連接資料庫伺服器的基本功能。
既然它是一個包，那麼我們首先學會導入這個包
#! /usr/bin/env python3
# coding: utf-8
from mysql import connector
print('導入成功')
執行以上代碼
$ python3 test_connector.py
導入成功
表示我們成功導入了相關的包或者模塊
連接器語法
要學習連接器語法，我們可以參考:https://dev.mysql.com/doc/connector-python/en/
連接
連接有兩個部分，不可或缺：
-
連接信息：
主機、埠、用戶名、密碼和資料庫名db_config = {'host': 'localhost',#主機'port': 3306,#埠'user': '？？？',#用戶'passwd': '？？？',#密碼'db': 'python',#連接的資料庫}
-
連接函數：所有連接器都有的函數，名字叫
connectfrom mysql.connector import connect註意：該函數反回的是一個代表著連接的對象，我們可以把這個
連接對象看成是客戶端。
游標
游標是從一個特定的連接中獲取的，cnn中有一個cursor方法，可以返回一個游標對象。
cur = cnn.cursor()
操作資料庫都是通過游標來進行，一個連接可以產生多個游標。
游標，其中有一個execute方法，只需要把我們需要執行的SQL語句當作參數傳入其中，就可以讓連接器指揮MySQL伺服器執行語句。
註意： execute並沒有返回值
那麼，查處來的星系在哪呢？
其實，查出來的信息就在我們的游標中。
由於，我們查出來的數據都是以行的形式出現的（查出來的是一條條記錄），全部存在游標里，當我們迭代這個游標的時候，我們其實是依次的拿到了其中的行（記錄），每次輸出我們的迭代項的時候，我們就是輸出了其中的一行。
#! /usr/bin/env python3
# coding: utf-8
from mysql.connector import connect
db_config = {
'host': 'localhost',
'port': 3306,
'user': '？？？',
'passwd': '？？？',
'db': 'mysql', # 相當於自動USE
}
cnn = connect(**db_config)
cur = cnn.cursor()
print(cur.execute('SELECT Host, User, authentication_string FROM user'))
for i in cur:
print(i)
執行上面的代碼
tuple@MyVM:~/testgit/learning_connector$ python3 test_cursor.py
None
(bytearray(b'localhost'), bytearray(b'root'), b'*81BCF9486900824FB0A3746219755FC21C50D058')
(bytearray(b'localhost'), bytearray(b'mysql.sys'), b'*THISISNOTAVALIDPASSWORDTHATCANBEUSEDHERE')
(bytearray(b'localhost'), bytearray(b'debian-sys-maint'), b'*599D0C45E62D3A9D58D74C0C5008688F13738AE5')
(bytearray(b'%'), bytearray(b'tuple'), b'*6BB4837EB74329105EE4568DDA7DC67ED2CA2AD9')
連接器，會自動幫我們，在Python的數據類型，和Mysql數據類型中自動轉換。
關閉
使用連接器，和使用文件一樣，一定要記得關閉，順序是
- 先關游標
- 再關連接
#! /usr/bin/env python3
# coding: utf-8
from mysql.connector import connect
db_config = {
'host': 'localhost',
'port': 3306,
'user': '？？？',
'passwd': '？？？',
'db': 'python', # 相當於自動USE
}
cnn = connect(**db_config)
cur = cnn.cursor()
sql_1 = '''
CREATE TABLE `from_connector` (
`id` int PRIMARY KEY auto_increment,
`name` varchar(20) NOT NULL
)
'''
sql_2 = '''
SHOW TABLES
'''
cur.execute(sql_1)
cur.execute(sql_2)
for i in cur:
print(i)
cur.close()
cnn.close()
ps:具有更好的東西，希望能夠跟大家多多交流學習；
