建站
咨詢
售后
建站咨詢
新聞中心
MySQL是使用廣泛的開源關(guān)系型數(shù)據(jù)庫管理系統(tǒng)，許多公司和組織在生產(chǎn)環(huán)境中使用MySQL來管理其數(shù)據(jù)。Python作為一種流行的編程語言，可以與MySQL數(shù)據(jù)庫進(jìn)行交互，并且可以很容易地創(chuàng)建和管理MySQL數(shù)據(jù)庫。
本文將介紹如何使用Python創(chuàng)建MySQL數(shù)據(jù)庫，包括以下步驟：
1. 安裝MySQL Connector/Python
在使用Python與MySQL交互之前，需要安裝MySQL Connector/Python?？梢詮腗ySQL官方網(wǎng)站下載Connector/Python，安裝方法也比較簡單，可以按照提示進(jìn)行安裝。
2. 創(chuàng)建MySQL數(shù)據(jù)庫
在創(chuàng)建MySQL數(shù)據(jù)庫之前，我們需要先登錄MySQL服務(wù)器?？梢允褂靡韵旅睿?/p>
“`bash
mysql -u username -p
“`
其中，username是你的MySQL用戶名。輸入命令后，會(huì)提示輸入密碼。輸入密碼后，即可登錄到MySQL服務(wù)器。
然后，在MySQL服務(wù)器上使用以下命令創(chuàng)建MySQL數(shù)據(jù)庫：
“`mysql
CREATE DATABASE example;
“`
其中，example是你要?jiǎng)?chuàng)建的數(shù)據(jù)庫名稱。使用該命令后，會(huì)在MySQL服務(wù)器上創(chuàng)建一個(gè)名為example的數(shù)據(jù)庫，你可以在其中創(chuàng)建表和插入數(shù)據(jù)等。
3. 使用Python創(chuàng)建MySQL表
可以使用MySQL Connector/Python庫與Python交互，以便在MySQL中創(chuàng)建表。下面是一個(gè)示例Python程序，用于創(chuàng)建一個(gè)名為“employees”的表：
“`python
import mysql.connector
db = mysql.connector.connect(
host=”localhost”,
user=”yourusername”,
password=”yourpassword”,
database=”example”
)
cursor = db.cursor()
cursor.execute(“CREATE TABLE employees (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), address VARCHAR(255))”)
“`
在這個(gè)Python腳本中，我們使用了MySQL Connector/Python庫連接到MySQL服務(wù)器。然后，我們將數(shù)據(jù)庫詳細(xì)信息賦值給db變量，并使用該變量創(chuàng)建指向該數(shù)據(jù)庫的游標(biāo)對(duì)象cursor。我們?cè)贛ySQL中創(chuàng)建了一個(gè)名為employees的表，其中包括三個(gè)列：id、name和address。
4. 向MySQL表中插入數(shù)據(jù)
使用Python將數(shù)據(jù)插入MySQL表非常容易。下面是一個(gè)示例Python程序，用于將數(shù)據(jù)插入“employees”表：
“`python
import mysql.connector
db = mysql.connector.connect(
host=”localhost”,
user=”yourusername”,
password=”yourpassword”,
database=”example”
)
cursor = db.cursor()
sql = “INSERT INTO employees (name, address) VALUES (%s, %s)”
val = (“John”, “Highway 21”)
cursor.execute(sql, val)
db.commit()
print(cursor.rowcount, “record inserted.”)
“`
在這個(gè)Python腳本中，我們將數(shù)據(jù)插入“employees”表。我們定義一個(gè)SQL語句，需要從Python變量中獲取數(shù)據(jù)。然后，我們將要插入表中的數(shù)據(jù)作為元組傳遞給execute()方法。在執(zhí)行execute()方法后，我們使用commit()方法提交更改到MySQL服務(wù)器中。
5. 從MySQL表中查詢數(shù)據(jù)
向表中插入數(shù)據(jù)后，我們可能需要從表中檢索數(shù)據(jù)。下面是一個(gè)示例Python程序，用于從“employees”表中檢索數(shù)據(jù)：
“`python
import mysql.connector
db = mysql.connector.connect(
host=”localhost”,
user=”yourusername”,
password=”yourpassword”,
database=”example”
)
cursor = db.cursor()
cursor.execute(“SELECT * FROM employees”)
result = cursor.fetchall()
for x in result:
print(x)
“`
在這個(gè)Python腳本中，我們使用execute()方法執(zhí)行SQL查詢。然后，我們可以使用fetchall()方法檢索所選行，并將它們作為元組對(duì)象列表返回。在這里，我們將結(jié)果打印出來。
Python與MySQL集成提供了一種強(qiáng)大的方式，通過使用Python創(chuàng)建和管理MySQL數(shù)據(jù)庫，可以輕松完成多種數(shù)據(jù)管理任務(wù)。本文介紹了一些基本的Python和MySQL庫示例，以幫助讀者入門這項(xiàng)技術(shù)并更好地理解其用途和相關(guān)內(nèi)部原理。
相關(guān)問題拓展閱讀：
- 如何用python寫sql
- python怎樣將數(shù)據(jù)存入mysql數(shù)據(jù)庫
如何用python寫sql
python可以利用pymysql模塊操作數(shù)據(jù)庫。
什么是 PyMySQL？
PyMySQL 是在 Python3.x 版本中用于連接 MySQL 服務(wù)器的一個(gè)庫，Python2中則使用旅敬mysqldb。
PyMySQL 遵讓拍循 Python 數(shù)據(jù)庫 API v2.0 規(guī)范，并包含了 pure-Python MySQL 客戶端庫。
PyMySQL 安裝
在使用 PyMySQL 之前，我們需要確保 PyMySQL 已安裝。
PyMySQL 下載ySQL。
如果還未安裝，我們可以使用以下命令安裝最新版的 PyMySQL：
$ pip3 install PyMySQL
如果你的系統(tǒng)不支持 pip 命令，可以使用以下方式安裝：
1、使用 git 命令下載
安裝包
安裝(你也可以手動(dòng)下載)：
$ git clone cd PyMySQL/$ python3 setup.py install
2、如果需要制定
版本號(hào)
，可以使用 curl 命令來安裝：
$ # X.X 為 PyMySQL 的版本號(hào)$ curl -L | tar xz$ cd PyMySQL*$ python3 setup.py install
$ # 現(xiàn)在你可以刪除 PyMySQL* 目錄
注意：請(qǐng)確保您有
root權(quán)限
來安裝上述模塊。
安裝的過程中可能會(huì)出現(xiàn)”ImportError: No module named setuptools”的錯(cuò)誤提示，意思是你沒有安裝setuptools，你可以訪問
.org
/pypi/setuptools 找到各個(gè)系統(tǒng)的安裝方法。
Linux 系統(tǒng)安裝實(shí)例：
$ wget python3 ez_setup.py
數(shù)據(jù)庫連接
連接數(shù)據(jù)庫前，請(qǐng)先確認(rèn)以下事項(xiàng)：
您已經(jīng)創(chuàng)建了數(shù)據(jù)庫 TESTDB.
在TESTDB數(shù)據(jù)庫中您已經(jīng)創(chuàng)建了表 EMPLOYEE
EMPLOYEE表字段為 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。
連接數(shù)據(jù)庫TESTDB使用的
用戶名
為 “testuser” ，密碼為 “test123”,你可以可以自己設(shè)定或者直接使用root用戶名及其密碼，Mysql數(shù)據(jù)庫用戶授權(quán)請(qǐng)使用Grant命令。
在你的機(jī)子上已經(jīng)安裝了 Python MySQLdb 模塊。
如果您對(duì)
sql語句
不熟悉，可以訪問我們的 SQL基礎(chǔ)教程
實(shí)例：
以下實(shí)例鏈接 Mysql 的 TESTDB 數(shù)據(jù)庫：
實(shí)例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開數(shù)據(jù)庫連接db = pymysql.connect(“l(fā)ocalhost”,”testuser”,”test123″,”TESTDB” )
# 使用 cursor() 方法創(chuàng)建一個(gè)
游標(biāo)
對(duì)象 cursorcursor = db.cursor()
# 使用 execute() 方法執(zhí)行 SQL 查詢 cursor.execute(“SELECT VERSION()”)
# 使用 fetchone() 方法獲取單條數(shù)據(jù).data = cursor.fetchone()
print (“Database version : %s ” % data)
# 關(guān)閉數(shù)據(jù)庫連接db.close()
執(zhí)行以上腳本輸出結(jié)果如下：
Database version : 5.5.20-log
創(chuàng)建數(shù)據(jù)庫表
如果數(shù)據(jù)庫連接存在我們拆滑慎可以使用execute()方法來為數(shù)據(jù)庫創(chuàng)建表，如下所示創(chuàng)建表EMPLOYEE：
實(shí)例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開數(shù)據(jù)庫連接db = pymysql.connect(“l(fā)ocalhost”,”testuser”,”test123″,”TESTDB” )
# 使用 cursor() 方法創(chuàng)建一個(gè)游標(biāo)對(duì)象 cursorcursor = db.cursor()
# 使用 execute() 方法執(zhí)行 SQL，如果表存在則刪除cursor.execute(“DROP TABLE IF EXISTS EMPLOYEE”)
# 使用預(yù)處理語句創(chuàng)建表sql = “””CREATE TABLE EMPLOYEE (
FIRST_NAME CHAR(20) NOT NULL,
LAST_NAME CHAR(20),
AGE INT,
SEX CHAR(1),
INCOME FLOAT )”””
cursor.execute(sql)
# 關(guān)閉數(shù)據(jù)庫連接db.close()
數(shù)據(jù)庫插入操作
以下實(shí)例使用執(zhí)行 SQL INSERT 語句向表 EMPLOYEE 插入記錄：
實(shí)例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開數(shù)據(jù)庫連接db = pymysql.connect(“l(fā)ocalhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標(biāo) cursor = db.cursor()
# SQL 插入語句sql = “””INSERT INTO EMPLOYEE(FIRST_NAME,
LAST_NAME, AGE, SEX, INCOME)
VALUES (‘Mac’, ‘Mohan’, 20, ‘M’, 2023)”””try: # 執(zhí)行sql語句
cursor.execute(sql)
# 提交到數(shù)據(jù)庫執(zhí)行
db.commit()except: # 如果發(fā)生錯(cuò)誤則回滾
db.rollback()
# 關(guān)閉數(shù)據(jù)庫連接db.close()
以上例子也可以寫成如下形式：
實(shí)例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開數(shù)據(jù)庫連接db = pymysql.connect(“l(fā)ocalhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標(biāo) cursor = db.cursor()
# SQL 插入語句sql = “INSERT INTO EMPLOYEE(FIRST_NAME, \
LAST_NAME, AGE, SEX, INCOME) \
VALUES (‘%s’, ‘%s’, %s, ‘%s’, %s)” % \(‘Mac’, ‘Mohan’, 20, ‘M’, 2023)try: # 執(zhí)行sql語句
cursor.execute(sql)
# 執(zhí)行sql語句
db.commit()except: # 發(fā)生錯(cuò)誤時(shí)回滾
db.rollback()
# 關(guān)閉數(shù)據(jù)庫連接db.close()
以下代碼使用變量向SQL語句中傳遞參數(shù):
…………………………….user_id = “test123″password = “password”con.execute(‘insert into Login values( %s, %s)’ % \(user_id, password))…………………………….
數(shù)據(jù)庫查詢操作
Python查詢Mysql使用 fetchone() 方法獲取單條數(shù)據(jù), 使用fetchall() 方法獲取多條數(shù)據(jù)。
fetchone(): 該方法獲取下一個(gè)查詢結(jié)果集。結(jié)果集是一個(gè)對(duì)象
fetchall(): 接收全部的返回結(jié)果行.
rowcount: 這是一個(gè)只讀屬性，并返回執(zhí)行execute()方法后影響的行數(shù)。
實(shí)例：
查詢EMPLOYEE表中salary（工資）字段大于1000的所有數(shù)據(jù)：
實(shí)例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開數(shù)據(jù)庫連接db = pymysql.connect(“l(fā)ocalhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標(biāo) cursor = db.cursor()
# SQL 查詢語句sql = “SELECT * FROM EMPLOYEE \
WHERE INCOME > %s” % (1000)try: # 執(zhí)行SQL語句
cursor.execute(sql)
# 獲取所有記錄列表
results = cursor.fetchall()
for row in results: fname = row
lname = row
age = row
sex = row
income = row
# 打印結(jié)果
print (“fname=%s,lname=%s,age=%s,sex=%s,income=%s” % \(fname, lname, age, sex, income ))except: print (“Error: unable to fetch data”)
# 關(guān)閉數(shù)據(jù)庫連接db.close()
以上腳本執(zhí)行結(jié)果如下：
fname=Mac, lname=Mohan, age=20, sex=M, income=2023
數(shù)據(jù)庫更新操作
更新操作用于更新數(shù)據(jù)表的的數(shù)據(jù)，以下實(shí)例將 TESTDB 表中 SEX 為 ‘M’ 的 AGE 字段遞增 1：
實(shí)例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開數(shù)據(jù)庫連接db = pymysql.connect(“l(fā)ocalhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標(biāo) cursor = db.cursor()
# SQL 更新語句sql = “UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = ‘%c'” % (‘M’)try: # 執(zhí)行SQL語句
cursor.execute(sql)
# 提交到數(shù)據(jù)庫執(zhí)行
db.commit()except: # 發(fā)生錯(cuò)誤時(shí)回滾
db.rollback()
# 關(guān)閉數(shù)據(jù)庫連接db.close()
刪除操作
刪除操作用于刪除數(shù)據(jù)表中的數(shù)據(jù)，以下實(shí)例演示了刪除數(shù)據(jù)表 EMPLOYEE 中 AGE 大于 20 的所有數(shù)據(jù)：
實(shí)例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開數(shù)據(jù)庫連接db = pymysql.connect(“l(fā)ocalhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標(biāo) cursor = db.cursor()
# SQL 刪除語句sql = “DELETE FROM EMPLOYEE WHERE AGE > %s” % (20)try: # 執(zhí)行SQL語句
cursor.execute(sql)
# 提交修改
db.commit()except: # 發(fā)生錯(cuò)誤時(shí)回滾
db.rollback()
# 關(guān)閉連接db.close()
執(zhí)行事務(wù)
事務(wù)機(jī)制可以確保數(shù)據(jù)一致性。
事務(wù)應(yīng)該具有4個(gè)屬性：
原子性
、一致性、隔離性、持久性。這四個(gè)屬性通常稱為ACID特性。
原子性（atomicity）。一個(gè)事務(wù)是一個(gè)不可分割的工作單位，事務(wù)中包括的諸操作要么都做，要么都不做。
一致性（consistency）。事務(wù)必須是使數(shù)據(jù)庫從一個(gè)一致性狀態(tài)變到另一個(gè)一致性狀態(tài)。一致性與原子性是密切相關(guān)的。
隔離性（isolation）。一個(gè)事務(wù)的執(zhí)行不能被其他事務(wù)干擾。即一個(gè)事務(wù)內(nèi)部的操作及使用的數(shù)據(jù)對(duì)并發(fā)的其他事務(wù)是隔離的，并發(fā)執(zhí)行的各個(gè)事務(wù)之間不能互相干擾。
持久性（durability）。持續(xù)性也稱永久性（permanence），指一個(gè)事務(wù)一旦提交，它對(duì)數(shù)據(jù)庫中數(shù)據(jù)的改變就應(yīng)該是永久性的。接下來的其他操作或故障不應(yīng)該對(duì)其有任何影響。
Python DB API 2.0 的事務(wù)提供了兩個(gè)方法 commit 或 rollback。
實(shí)例
實(shí)例(Python 3.0+)
# SQL刪除記錄語句sql = “DELETE FROM EMPLOYEE WHERE AGE > %s” % (20)try: # 執(zhí)行SQL語句
cursor.execute(sql)
# 向數(shù)據(jù)庫提交
db.commit()except: # 發(fā)生錯(cuò)誤時(shí)回滾
db.rollback()
對(duì)于支持事務(wù)的數(shù)據(jù)庫， 在Python數(shù)據(jù)庫編程中，當(dāng)游標(biāo)建立之時(shí)，就自動(dòng)開始了一個(gè)隱形的數(shù)據(jù)庫事務(wù)。
commit()方法游標(biāo)的所有更新操作，rollback（）方法回滾當(dāng)前游標(biāo)的所有操作。每一個(gè)方法都開始了一個(gè)新的事務(wù)。
錯(cuò)誤處理
DB API中定義了一些數(shù)據(jù)庫操作的錯(cuò)誤及異常，下表列出了這些錯(cuò)誤和異常:
異常
描述
Warning 當(dāng)有嚴(yán)重警告時(shí)觸發(fā)，例如插入數(shù)據(jù)是被截?cái)嗟鹊?。必須?StandardError 的子類。
Error 警告以外所有其他錯(cuò)誤類。必須是 StandardError 的子類。
InterfaceError 當(dāng)有數(shù)據(jù)庫接口模塊本身的錯(cuò)誤（而不是數(shù)據(jù)庫的錯(cuò)誤）發(fā)生時(shí)觸發(fā)。 必須是Error的子類。
DatabaseError 和數(shù)據(jù)庫有關(guān)的錯(cuò)誤發(fā)生時(shí)觸發(fā)。 必須是Error的子類。
DataError 當(dāng)有數(shù)據(jù)處理時(shí)的錯(cuò)誤發(fā)生時(shí)觸發(fā)，例如：除零錯(cuò)誤，數(shù)據(jù)超范圍等等。 必須是DatabaseError的子類。
OperationalError 指非用戶控制的，而是操作數(shù)據(jù)庫時(shí)發(fā)生的錯(cuò)誤。例如：連接意外斷開、 數(shù)據(jù)庫名未找到、事務(wù)處理失敗、內(nèi)存分配錯(cuò)誤等等操作數(shù)據(jù)庫是發(fā)生的錯(cuò)誤。 必須是DatabaseError的子類。
IntegrityError 完整性相關(guān)的錯(cuò)誤，例如外鍵檢查失敗等。必須是DatabaseError子類。
InternalError 數(shù)據(jù)庫的內(nèi)部錯(cuò)誤，例如游標(biāo)（cursor）失效了、事務(wù)同步失敗等等。 必須是DatabaseError子類。
ProgrammingError 程序錯(cuò)誤，例如數(shù)據(jù)表（table）沒找到或已存在、SQL語句語法錯(cuò)誤、 參數(shù)數(shù)量錯(cuò)誤等等。必須是DatabaseError的子類。
python怎樣將數(shù)據(jù)存入mysql數(shù)據(jù)庫
import 第三方庫啊，然后用insert into 語句執(zhí)行
下載猛念模mysql.connector庫
然后把爬蟲爬到的數(shù)據(jù)通過mysql里面的insert語句查到數(shù)據(jù)庫，當(dāng)然也可以建表，一般我沒用python建表枝緩 是先建好再寫數(shù)據(jù)的
import mysql.connector
conn = mysql.connector.connect(
user=’root’,
password=’root’,
host=’127.0.0.1′,
port=’3306′,
database=’高手test_demo’
)
cursor = conn.cursor()
cursor.execute(“INSERT INTO test_user(`uuid`,`user_name`,`user_level`) VALUES (%s,%s,%s)”,)
cursor.execute(“INSERT INTO tieba_user_detail(`user_name`,`user_exp`,`user_sex`,`tieba_age`,`tieba_note`,`user_favorites`,`user_fans`) VALUES (%s,%s,%s,%s,%s,%s,%s)”,)
print(‘************** %s %s 數(shù)據(jù)保存成功 **************’%(user_rank,user_name))
conn.commit()
cursor.close()
python 創(chuàng)建mysql數(shù)據(jù)庫的介紹就聊到這里吧，感謝你花時(shí)間閱讀本站內(nèi)容，更多關(guān)于python 創(chuàng)建mysql數(shù)據(jù)庫,Python輕松創(chuàng)建MySQL數(shù)據(jù)庫,如何用python寫sql,python怎樣將數(shù)據(jù)存入mysql數(shù)據(jù)庫的信息別忘了在本站進(jìn)行查找喔。
成都服務(wù)器托管選創(chuàng)新互聯(lián)，先上架開通再付費(fèi)。
創(chuàng)新互聯(lián)（www.cdcxhl.com）專業(yè)-網(wǎng)站建設(shè),軟件開發(fā)老牌服務(wù)商！微信小程序開發(fā),APP開發(fā),網(wǎng)站制作，網(wǎng)站營銷推廣服務(wù)眾多企業(yè)。電話：028-86922220
名稱欄目：Python輕松創(chuàng)建MySQL數(shù)據(jù)庫 (python 創(chuàng)建mysql數(shù)據(jù)庫)
當(dāng)前路徑：http://www.fisionsoft.com.cn/article/cdcggce.html
