它們往往是一類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',#連接的數據庫
}
連接函數:所有連接器都有的函數,名字叫connect
from 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:具有更好的東西,希望能夠跟大家多多交流學習;