MySQL Connector / Python允許Python程序使用符合Python數據庫API規范v2.0（PEP 249）的API訪問MySQL數據庫?。

MySQL Connector / Python包括對以下內容的支持：

幾乎所有MySQL Server提供的功能都包括MySQL Server版本5.7。

Connector / Python 8.0也支持X DevAPI。有關使用X DevAPI的MySQL Connector / Python的概念和用法的文檔，請參閱 X DevAPI用戶指南。

在Python和MySQL數據類型之間來回轉換參數值，例如Python datetime 和MySQL DATETIME。為方便起見，您可以打開自動轉換，或者關閉以獲得最佳性能。

標準SQL語法的所有MySQL擴展。

協議壓縮，可以壓縮客戶端和服務器之間的數據流。

使用TCP / IP套接字的連接和使用Unix套接字的Unix連接。

使用SSL保護TCP / IP連接。

獨立的驅動。Connector / Python不需要MySQL客戶端庫或標準庫之外的任何Python模塊。

1使用Connector / Python連接MySQL
該connect()構造函數創建到MySQL服務器的連接并返回一個 MySQLConnection對象。

以下示例顯示如何連接到MySQL服務器：

import mysql.connector

cnx = mysql.connector.connect(user='scott', password='password',
host='127.0.0.1',
database='employees')
cnx.close()

也可以使用connection.MySQLConnection（） 類創建連接對象 ：

from mysql.connector import (connection)

cnx = connection.MySQLConnection(user='scott', password='password',
host='127.0.0.1',
database='employees')
cnx.close()
兩種形式（使用connect() 構造函數或直接使用類）都是有效且功能相同的，但是connect()本手冊中的大多數示例都是首選使用的。

要處理連接錯誤，請使用該try 語句并使用errors.Error 異常捕獲所有錯誤 ：

import mysql.connector
from mysql.connector import errorcode

try:
cnx = mysql.connector.connect(user='scott',
database='employ')
except mysql.connector.Error as err:
if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:
print("Something is wrong with your user name or password")
elif err.errno == errorcode.ER_BAD_DB_ERROR:
print("Database does not exist")
else:
print(err)
else:
cnx.close()
在字典中定義連接參數并使用 **運算符是另一種選擇：

import mysql.connector

config = {
'user': 'scott',
'password': 'password',
'host': '127.0.0.1',
'database': 'employees',
'raise_on_warnings': True
}

cnx = mysql.connector.connect(**config)

cnx.close()

2使用Connector / Python創建表
所有DDL（數據定義語言）語句都使用稱為游標的句柄結構執行。以下示例顯示如何創建Employee示例數據庫的表 。你需要它們用于其他例子。

在MySQL服務器中，表是非常長壽的對象，并且通常由以不同語言編寫的多個應用程序訪問。您通常可以使用已設置的表，而不是在自己的應用程序中創建它們。避免一遍又一遍地設置和丟棄表，因為這是一項昂貴的操作。臨時表是一個例外 ，可以在應用程序中快速創建和刪除。

from __future__ import print_function

import mysql.connector
from mysql.connector import errorcode

DB_NAME = 'employees'

TABLES = {}
TABLES['employees'] = (
"CREATE TABLE `employees` ("
" `emp_no` int(11) NOT NULL AUTO_INCREMENT,"
" `birth_date` date NOT NULL,"
" `first_name` varchar(14) NOT NULL,"
" `last_name` varchar(16) NOT NULL,"
" `gender` enum('M','F') NOT NULL,"
" `hire_date` date NOT NULL,"
" PRIMARY KEY (`emp_no`)"
") ENGINE=InnoDB")

TABLES['departments'] = (
"CREATE TABLE `departments` ("
" `dept_no` char(4) NOT NULL,"
" `dept_name` varchar(40) NOT NULL,"
" PRIMARY KEY (`dept_no`), UNIQUE KEY `dept_name` (`dept_name`)"
") ENGINE=InnoDB")

TABLES['salaries'] = (
"CREATE TABLE `salaries` ("
" `emp_no` int(11) NOT NULL,"
" `salary` int(11) NOT NULL,"
" `from_date` date NOT NULL,"
" `to_date` date NOT NULL,"
" PRIMARY KEY (`emp_no`,`from_date`), KEY `emp_no` (`emp_no`),"
" CONSTRAINT `salaries_ibfk_1` FOREIGN KEY (`emp_no`) "
" REFERENCES `employees` (`emp_no`) ON DELETE CASCADE"
") ENGINE=InnoDB")

TABLES['dept_emp'] = (
"CREATE TABLE `dept_emp` ("
" `emp_no` int(11) NOT NULL,"
" `dept_no` char(4) NOT NULL,"
" `from_date` date NOT NULL,"
" `to_date` date NOT NULL,"
" PRIMARY KEY (`emp_no`,`dept_no`), KEY `emp_no` (`emp_no`),"
" KEY `dept_no` (`dept_no`),"
" CONSTRAINT `dept_emp_ibfk_1` FOREIGN KEY (`emp_no`) "
" REFERENCES `employees` (`emp_no`) ON DELETE CASCADE,"
" CONSTRAINT `dept_emp_ibfk_2` FOREIGN KEY (`dept_no`) "
" REFERENCES `departments` (`dept_no`) ON DELETE CASCADE"
") ENGINE=InnoDB")

TABLES['dept_manager'] = (
" CREATE TABLE `dept_manager` ("
" `dept_no` char(4) NOT NULL,"
" `emp_no` int(11) NOT NULL,"
" `from_date` date NOT NULL,"
" `to_date` date NOT NULL,"
" PRIMARY KEY (`emp_no`,`dept_no`),"
" KEY `emp_no` (`emp_no`),"
" KEY `dept_no` (`dept_no`),"
" CONSTRAINT `dept_manager_ibfk_1` FOREIGN KEY (`emp_no`) "
" REFERENCES `employees` (`emp_no`) ON DELETE CASCADE,"
" CONSTRAINT `dept_manager_ibfk_2` FOREIGN KEY (`dept_no`) "
" REFERENCES `departments` (`dept_no`) ON DELETE CASCADE"
") ENGINE=InnoDB")

TABLES['titles'] = (
"CREATE TABLE `titles` ("
" `emp_no` int(11) NOT NULL,"
" `title` varchar(50) NOT NULL,"
" `from_date` date NOT NULL,"
" `to_date` date DEFAULT NULL,"
" PRIMARY KEY (`emp_no`,`title`,`from_date`), KEY `emp_no` (`emp_no`),"
" CONSTRAINT `titles_ibfk_1` FOREIGN KEY (`emp_no`)"
" REFERENCES `employees` (`emp_no`) ON DELETE CASCADE"
") ENGINE=InnoDB")
上面的代碼顯示了我們如何將CREATE語句存儲在 名為的Python字典中 TABLES。我們還在一個名為的全局變量中定義數據庫DB_NAME，這使您可以輕松使用不同的模式。

cnx = mysql.connector.connect(user='scott')
cursor = cnx.cursor()
單個MySQL服務器可以管理多個 數據庫。通常，您指定要在連接到MySQL服務器時切換到的數據庫。此示例在連接時不連接到數據庫，因此它可以確保數據庫存在，如果不存在則創建它：

def create_database(cursor):
try:
cursor.execute(
"CREATE DATABASE {} DEFAULT CHARACTER SET 'utf8'".format(DB_NAME))
except mysql.connector.Error as err:
print("Failed creating database: {}".format(err))
exit(1)

try:
cursor.execute("USE {}".format(DB_NAME))
except mysql.connector.Error as err:
print("Database {} does not exists.".format(DB_NAME))
if err.errno == errorcode.ER_BAD_DB_ERROR:
create_database(cursor)
print("Database {} created successfully.".format(DB_NAME))
cnx.database = DB_NAME
else:
print(err)
exit(1)
我們首先嘗試使用database連接對象的屬性 更改為特定數據庫 cnx。如果有錯誤，我們檢查錯誤號以檢查數據庫是否不存在。如果是這樣，我們調用 create_database函數為我們創建它。

在任何其他錯誤上，應用程序退出并顯示錯誤消息。

在我們成功創建或更改目標數據庫之后，我們通過迭代TABLES字典的項來創建表 ：

for table_name in TABLES:
table_description = TABLES[table_name]
try:
print("Creating table {}: ".format(table_name), end='')
cursor.execute(table_description)
except mysql.connector.Error as err:
if err.errno == errorcode.ER_TABLE_EXISTS_ERROR:
print("already exists.")
else:
print(err.msg)
else:
print("OK")

cursor.close()
cnx.close()
要在表已存在時處理錯誤，我們會通知用戶它已經存在。打印其他錯誤，但我們繼續創建表。（該示例顯示了如何處理 “ 表已存在 ”條件以用于說明目的。在實際應用程序中，我們通常通過使用語句的IF NOT EXISTS子句完全避免錯誤條件CREATE TABLE。）

輸出將是這樣的：

Database employees does not exists.
Database employees created successfully.
Creating table employees: OK
Creating table departments: already exists.
Creating table salaries: already exists.
Creating table dept_emp: OK
Creating table dept_manager: OK
Creating table titles: OK
要填充employees表，請使用Employee Sample Database的轉儲文件 。請注意，您只需要在名為的存檔中找到的數據轉儲文件 employees_db-dump-files-1.0.5.tar.bz2。下載轉儲文件后，執行以下命令，必要時向mysql命令添加連接選項：

shell> tar xzf employees_db-dump-files-1.0.5.tar.bz2
shell> cd employees_db
shell> mysql employees < load_employees.dump
shell> mysql employees < load_titles.dump
shell> mysql employees < load_departments.dump
shell> mysql employees < load_salaries.dump
shell> mysql employees < load_dept_emp.dump
shell> mysql employees < load_dept_manager.dump

3使用Connector / Python插入數據
使用稱為游標的處理程序結構也可以完成插入或更新數據。當您使用事務性存儲引擎，如InnoDB（在MySQL 5.5和更高的默認設置），則必須提交 的序列后的數據 INSERT， DELETE以及 UPDATE報表。

此示例顯示如何插入新數據。第二個 INSERT取決于第一個新創建的主鍵的值 。該示例還演示了如何使用擴展格式。任務是添加一名新員工，明天開始工作，薪水設置為50000。

注意
以下示例使用示例 “使用Connector / Python創建表”中創建的表。表AUTO_INCREMENT的主鍵的 列選項對于employees確保可靠，易于搜索的數據非常重要。

from __future__ import print_function
from datetime import date, datetime, timedelta
import mysql.connector

cnx = mysql.connector.connect(user='scott', database='employees')
cursor = cnx.cursor()

tomorrow = datetime.now().date() + timedelta(days=1)

add_employee = ("INSERT INTO employees "
"(first_name, last_name, hire_date, gender, birth_date) "
"VALUES (%s, %s, %s, %s, %s)")
add_salary = ("INSERT INTO salaries "
"(emp_no, salary, from_date, to_date) "
"VALUES (%(emp_no)s, %(salary)s, %(from_date)s, %(to_date)s)")

data_employee = ('Geert', 'Vanderkelen', tomorrow, 'M', date(1977, 6, 14))

# Insert new employee
cursor.execute(add_employee, data_employee)
emp_no = cursor.lastrowid

# Insert salary information
data_salary = {
'emp_no': emp_no,
'salary': 50000,
'from_date': tomorrow,
'to_date': date(9999, 1, 1),
}
cursor.execute(add_salary, data_salary)

# Make sure data is committed to the database
cnx.commit()

cursor.close()
cnx.close()
我們首先打開與MySQL服務器的連接，并將連接對象存儲 在變量中cnx。然后 ，我們使用連接的 方法創建一個新的游標，默認情況下是一個 MySQLCursor對象 cursor()。

4使用Connector / Python查詢數據
以下示例說明如何使用使用連接 方法創建的游標來 查詢數據 cursor()。返回的數據被格式化并打印在控制臺上。

任務是選擇1999年雇用的所有員工，并將他們的姓名和雇用日期打印到控制臺。

import datetime
import mysql.connector

cnx = mysql.connector.connect(user='scott', database='employees')
cursor = cnx.cursor()

query = ("SELECT first_name, last_name, hire_date FROM employees "
"WHERE hire_date BETWEEN %s AND %s")

hire_start = datetime.date(1999, 1, 1)
hire_end = datetime.date(1999, 12, 31)

cursor.execute(query, (hire_start, hire_end))

for (first_name, last_name, hire_date) in cursor:
print("{}, {} was hired on {:%d %b %Y}".format(
last_name, first_name, hire_date))

cursor.close()
cnx.close()
我們首先打開與MySQL服務器的連接，并將連接對象存儲 在變量中cnx。然后 ，我們使用連接的 方法創建一個新的游標，默認情況下是一個 MySQLCursor對象 cursor()。

5以下示例腳本明天向所有加入2000年且仍在公司的員工提交了15％的提前生效。

為了遍歷選定的員工，我們使用緩沖游標。（緩沖的游標在執行查詢后獲取并緩沖結果集的行;請參見 第10.6.1節“cursor.MySQLCursorBuffered類”。）這樣，就不必獲取新變量中的行。相反，游標可以用作迭代器。

from __future__ import print_function

from decimal import Decimal
from datetime import datetime, date, timedelta

import mysql.connector

# Connect with the MySQL Server
cnx = mysql.connector.connect(user='scott', database='employees')

# Get two buffered cursors
curA = cnx.cursor(buffered=True)
curB = cnx.cursor(buffered=True)

# Query to get employees who joined in a period defined by two dates
query = (
"SELECT s.emp_no, salary, from_date, to_date FROM employees AS e "
"LEFT JOIN salaries AS s USING (emp_no) "
"WHERE to_date = DATE('9999-01-01')"
"AND e.hire_date BETWEEN DATE(%s) AND DATE(%s)")

# UPDATE and INSERT statements for the old and new salary
update_old_salary = (
"UPDATE salaries SET to_date = %s "
"WHERE emp_no = %s AND from_date = %s")
insert_new_salary = (
"INSERT INTO salaries (emp_no, from_date, to_date, salary) "
"VALUES (%s, %s, %s, %s)")

# Select the employees getting a raise
curA.execute(query, (date(2000, 1, 1), date(2000, 12, 31)))

# Iterate through the result of curA
for (emp_no, salary, from_date, to_date) in curA:

# Update the old and insert the new salary
new_salary = int(round(salary * Decimal('1.15')))
curB.execute(update_old_salary, (tomorrow, emp_no, from_date))
curB.execute(insert_new_salary,
(emp_no, tomorrow, date(9999, 1, 1,), new_salary))

# Commit the changes
cnx.commit()

cnx.close()

轉載于:https://www.cnblogs.com/XZY30/p/10666063.html

總結

以上是生活随笔為你收集整理的MySQL Connector / Python的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。