新聞中心
MySQL是使用廣泛的開源關(guān)系型數(shù)據(jù)庫管理系統(tǒng),許多公司和組織在生產(chǎn)環(huán)境中使用MySQL來管理其數(shù)據(jù)。Python作為一種流行的編程語言,可以與MySQL數(shù)據(jù)庫進行交互,并且可以很容易地創(chuàng)建和管理MySQL數(shù)據(jù)庫。

本文將介紹如何使用Python創(chuàng)建MySQL數(shù)據(jù)庫,包括以下步驟:
1. 安裝MySQL Connector/Python
在使用Python與MySQL交互之前,需要安裝MySQL Connector/Python。可以從MySQL官方網(wǎng)站下載Connector/Python,安裝方法也比較簡單,可以按照提示進行安裝。
2. 創(chuàng)建MySQL數(shù)據(jù)庫
在創(chuàng)建MySQL數(shù)據(jù)庫之前,我們需要先登錄MySQL服務(wù)器??梢允褂靡韵旅睿?/p>
“`bash
mysql -u username -p
“`
其中,username是你的MySQL用戶名。輸入命令后,會提示輸入密碼。輸入密碼后,即可登錄到MySQL服務(wù)器。
然后,在MySQL服務(wù)器上使用以下命令創(chuàng)建MySQL數(shù)據(jù)庫:
“`mysql
CREATE DATABASE example;
“`
其中,example是你要創(chuàng)建的數(shù)據(jù)庫名稱。使用該命令后,會在MySQL服務(wù)器上創(chuàng)建一個名為example的數(shù)據(jù)庫,你可以在其中創(chuàng)建表和插入數(shù)據(jù)等。
3. 使用Python創(chuàng)建MySQL表
可以使用MySQL Connector/Python庫與Python交互,以便在MySQL中創(chuàng)建表。下面是一個示例Python程序,用于創(chuàng)建一個名為“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))”)
“`
在這個Python腳本中,我們使用了MySQL Connector/Python庫連接到MySQL服務(wù)器。然后,我們將數(shù)據(jù)庫詳細信息賦值給db變量,并使用該變量創(chuàng)建指向該數(shù)據(jù)庫的游標對象cursor。我們在MySQL中創(chuàng)建了一個名為employees的表,其中包括三個列:id、name和address。
4. 向MySQL表中插入數(shù)據(jù)
使用Python將數(shù)據(jù)插入MySQL表非常容易。下面是一個示例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.”)
“`
在這個Python腳本中,我們將數(shù)據(jù)插入“employees”表。我們定義一個SQL語句,需要從Python變量中獲取數(shù)據(jù)。然后,我們將要插入表中的數(shù)據(jù)作為元組傳遞給execute()方法。在執(zhí)行execute()方法后,我們使用commit()方法提交更改到MySQL服務(wù)器中。
5. 從MySQL表中查詢數(shù)據(jù)
向表中插入數(shù)據(jù)后,我們可能需要從表中檢索數(shù)據(jù)。下面是一個示例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)
“`
在這個Python腳本中,我們使用execute()方法執(zhí)行SQL查詢。然后,我們可以使用fetchall()方法檢索所選行,并將它們作為元組對象列表返回。在這里,我們將結(jié)果打印出來。
Python與MySQL集成提供了一種強大的方式,通過使用Python創(chuàng)建和管理MySQL數(shù)據(jù)庫,可以輕松完成多種數(shù)據(jù)管理任務(wù)。本文介紹了一些基本的Python和MySQL庫示例,以幫助讀者入門這項技術(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ù)器的一個庫,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 命令下載
安裝包
安裝(你也可以手動下載):
$ git clone cd PyMySQL/$ python3 setup.py install
2、如果需要制定
版本號
,可以使用 curl 命令來安裝:
$ # X.X 為 PyMySQL 的版本號$ curl -L | tar xz$ cd PyMySQL*$ python3 setup.py install
$ # 現(xiàn)在你可以刪除 PyMySQL* 目錄
注意:請確保您有
root權(quán)限
來安裝上述模塊。
安裝的過程中可能會出現(xiàn)”ImportError: No module named setuptools”的錯誤提示,意思是你沒有安裝setuptools,你可以訪問
.org
/pypi/setuptools 找到各個系統(tǒng)的安裝方法。
Linux 系統(tǒng)安裝實例:
$ wget python3 ez_setup.py
數(shù)據(jù)庫連接
連接數(shù)據(jù)庫前,請先確認以下事項:
您已經(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)請使用Grant命令。
在你的機子上已經(jīng)安裝了 Python MySQLdb 模塊。
如果您對
sql語句
不熟悉,可以訪問我們的 SQL基礎(chǔ)教程
實例:
以下實例鏈接 Mysql 的 TESTDB 數(shù)據(jù)庫:
實例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開數(shù)據(jù)庫連接db = pymysql.connect(“l(fā)ocalhost”,”testuser”,”test123″,”TESTDB” )
# 使用 cursor() 方法創(chuàng)建一個
游標
對象 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:
實例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開數(shù)據(jù)庫連接db = pymysql.connect(“l(fā)ocalhost”,”testuser”,”test123″,”TESTDB” )
# 使用 cursor() 方法創(chuàng)建一個游標對象 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ù)庫插入操作
以下實例使用執(zhí)行 SQL INSERT 語句向表 EMPLOYEE 插入記錄:
實例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開數(shù)據(jù)庫連接db = pymysql.connect(“l(fā)ocalhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標 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ā)生錯誤則回滾
db.rollback()
# 關(guān)閉數(shù)據(jù)庫連接db.close()
以上例子也可以寫成如下形式:
實例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開數(shù)據(jù)庫連接db = pymysql.connect(“l(fā)ocalhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標 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ā)生錯誤時回滾
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(): 該方法獲取下一個查詢結(jié)果集。結(jié)果集是一個對象
fetchall(): 接收全部的返回結(jié)果行.
rowcount: 這是一個只讀屬性,并返回執(zhí)行execute()方法后影響的行數(shù)。
實例:
查詢EMPLOYEE表中salary(工資)字段大于1000的所有數(shù)據(jù):
實例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開數(shù)據(jù)庫連接db = pymysql.connect(“l(fā)ocalhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標 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ù),以下實例將 TESTDB 表中 SEX 為 ‘M’ 的 AGE 字段遞增 1:
實例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開數(shù)據(jù)庫連接db = pymysql.connect(“l(fā)ocalhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標 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ā)生錯誤時回滾
db.rollback()
# 關(guān)閉數(shù)據(jù)庫連接db.close()
刪除操作
刪除操作用于刪除數(shù)據(jù)表中的數(shù)據(jù),以下實例演示了刪除數(shù)據(jù)表 EMPLOYEE 中 AGE 大于 20 的所有數(shù)據(jù):
實例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開數(shù)據(jù)庫連接db = pymysql.connect(“l(fā)ocalhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標 cursor = db.cursor()
# SQL 刪除語句sql = “DELETE FROM EMPLOYEE WHERE AGE > %s” % (20)try: # 執(zhí)行SQL語句
cursor.execute(sql)
# 提交修改
db.commit()except: # 發(fā)生錯誤時回滾
db.rollback()
# 關(guān)閉連接db.close()
執(zhí)行事務(wù)
事務(wù)機制可以確保數(shù)據(jù)一致性。
事務(wù)應(yīng)該具有4個屬性:
原子性
、一致性、隔離性、持久性。這四個屬性通常稱為ACID特性。
原子性(atomicity)。一個事務(wù)是一個不可分割的工作單位,事務(wù)中包括的諸操作要么都做,要么都不做。
一致性(consistency)。事務(wù)必須是使數(shù)據(jù)庫從一個一致性狀態(tài)變到另一個一致性狀態(tài)。一致性與原子性是密切相關(guān)的。
隔離性(isolation)。一個事務(wù)的執(zhí)行不能被其他事務(wù)干擾。即一個事務(wù)內(nèi)部的操作及使用的數(shù)據(jù)對并發(fā)的其他事務(wù)是隔離的,并發(fā)執(zhí)行的各個事務(wù)之間不能互相干擾。
持久性(durability)。持續(xù)性也稱永久性(permanence),指一個事務(wù)一旦提交,它對數(shù)據(jù)庫中數(shù)據(jù)的改變就應(yīng)該是永久性的。接下來的其他操作或故障不應(yīng)該對其有任何影響。
Python DB API 2.0 的事務(wù)提供了兩個方法 commit 或 rollback。
實例
實例(Python 3.0+)
# SQL刪除記錄語句sql = “DELETE FROM EMPLOYEE WHERE AGE > %s” % (20)try: # 執(zhí)行SQL語句
cursor.execute(sql)
# 向數(shù)據(jù)庫提交
db.commit()except: # 發(fā)生錯誤時回滾
db.rollback()
對于支持事務(wù)的數(shù)據(jù)庫, 在Python數(shù)據(jù)庫編程中,當游標建立之時,就自動開始了一個隱形的數(shù)據(jù)庫事務(wù)。
commit()方法游標的所有更新操作,rollback()方法回滾當前游標的所有操作。每一個方法都開始了一個新的事務(wù)。
錯誤處理
DB API中定義了一些數(shù)據(jù)庫操作的錯誤及異常,下表列出了這些錯誤和異常:
異常
描述
Warning 當有嚴重警告時觸發(fā),例如插入數(shù)據(jù)是被截斷等等。必須是 StandardError 的子類。
Error 警告以外所有其他錯誤類。必須是 StandardError 的子類。
InterfaceError 當有數(shù)據(jù)庫接口模塊本身的錯誤(而不是數(shù)據(jù)庫的錯誤)發(fā)生時觸發(fā)。 必須是Error的子類。
DatabaseError 和數(shù)據(jù)庫有關(guān)的錯誤發(fā)生時觸發(fā)。 必須是Error的子類。
DataError 當有數(shù)據(jù)處理時的錯誤發(fā)生時觸發(fā),例如:除零錯誤,數(shù)據(jù)超范圍等等。 必須是DatabaseError的子類。
OperationalError 指非用戶控制的,而是操作數(shù)據(jù)庫時發(fā)生的錯誤。例如:連接意外斷開、 數(shù)據(jù)庫名未找到、事務(wù)處理失敗、內(nèi)存分配錯誤等等操作數(shù)據(jù)庫是發(fā)生的錯誤。 必須是DatabaseError的子類。
IntegrityError 完整性相關(guān)的錯誤,例如外鍵檢查失敗等。必須是DatabaseError子類。
InternalError 數(shù)據(jù)庫的內(nèi)部錯誤,例如游標(cursor)失效了、事務(wù)同步失敗等等。 必須是DatabaseError子類。
ProgrammingError 程序錯誤,例如數(shù)據(jù)表(table)沒找到或已存在、SQL語句語法錯誤、 參數(shù)數(shù)量錯誤等等。必須是DatabaseError的子類。
python怎樣將數(shù)據(jù)存入mysql數(shù)據(jù)庫
import 第三方庫啊,然后用insert into 語句執(zhí)行
下載猛念模mysql.connector庫
然后把爬蟲爬到的數(shù)據(jù)通過mysql里面的insert語句查到數(shù)據(jù)庫,當然也可以建表,一般我沒用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ù)庫的介紹就聊到這里吧,感謝你花時間閱讀本站內(nèi)容,更多關(guān)于python 創(chuàng)建mysql數(shù)據(jù)庫,Python輕松創(chuàng)建MySQL數(shù)據(jù)庫,如何用python寫sql,python怎樣將數(shù)據(jù)存入mysql數(shù)據(jù)庫的信息別忘了在本站進行查找喔。
成都服務(wù)器托管選創(chuàng)新互聯(lián),先上架開通再付費。
創(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ù)庫)
URL地址:http://m.5511xx.com/article/cdcggce.html


咨詢
建站咨詢
