Python連接Mysql進行增刪改查的示例代碼
Python連接Mysql
1.安裝對應的庫
使用Python連接Mysql數據庫需要安裝相應的庫
以管理員身份運行cmd,輸入命令
pip install mysql.connector
安裝完成后建立test.py寫入import mysql.connector保存后運行python test.py用以測試模塊庫是否安裝完成,如果不報錯,說明安裝完成
2.進行連接測試
編寫connectTest.py文件文件內容:
import mysql.connectorconnect = mysql.connector.connect( host='127.0.0.1', # 數據庫主機地址 user='root', # 數據庫用戶名 passwd='root', # 數據庫密碼 database='mysql' # 要連接的數據庫)#關閉連接connect.close()
運行文件python connectTest.py如果沒有報錯提示說明連接成功,如果報錯提示
說明連接失敗,請檢查賬戶、密碼以及數據庫是否正確,查看數據庫是否開機
3.執行sql命令
3.1創建表
import mysql.connectorconnect = mysql.connector.connect( host='127.0.0.1', # 數據庫主機地址 user='root', # 數據庫用戶名 passwd='root', # 數據庫密碼 database='test' # 要連接的數據庫)#數據庫建表指令sql = '''CREATE TABLE `test`.`testtable` ( `id` int NOT NULL, `name` varchar(255) NULL, `age` int NULL, `address` varchar(255) NULL, PRIMARY KEY (`id`) );'''#獲取數據庫操作游標myCursor=connect.cursor()#執行sql語句myCursor.execute(sql)#提交給數據庫執行命令connect.commit()connect.close()
執行后會創建一個名為testtabe的表
3.2插入數據
import mysql.connectorconnect = mysql.connector.connect( host='127.0.0.1', # 數據庫主機地址 user='root', # 數據庫用戶名 passwd='root', # 數據庫密碼 database='test' # 要連接的數據庫)# 數據庫插入指令,待定字符無論是數值還是文字,都需要用%ssql = 'INSERT INTO `test`.`testtable`(`id`, `name`, `age`, `address`) VALUES (%s,%s,%s,%s)'var = (1, ’windSnowLi’, 20, ’中國’)# 獲取數據庫操作游標myCursor = connect.cursor()try: # 執行sql語句 myCursor.execute(sql, var) # 提交給數據庫執行命令 connect.commit()except : #回滾,以防出現錯誤 connect.rollback()connect.close()
隨后檢查數據庫
3.3查詢語句
import mysql.connectorconnect = mysql.connector.connect( host='127.0.0.1', # 數據庫主機地址 user='root', # 數據庫用戶名 passwd='root', # 數據庫密碼 database='test' # 要連接的數據庫)# 數據庫查詢指令sql = 'select * from testtable'# 獲取數據庫操作游標myCursor = connect.cursor()try: # 執行sql語句 myCursor.execute(sql) results = myCursor.fetchall() print(results)except : print('查詢失敗')connect.close()
3.4更新數據
import mysql.connectorconnect = mysql.connector.connect( host='127.0.0.1', # 數據庫主機地址 user='root', # 數據庫用戶名 passwd='root', # 數據庫密碼 database='test' # 要連接的數據庫)# 數據庫更新指令sql = 'UPDATE `test`.`testtable` SET `id` = 2, `name` = ’mirror’, `age` = 19, `address` = ’祖國’ WHERE `id` = 1'# 獲取數據庫操作游標myCursor = connect.cursor()try: # 執行sql語句 myCursor.execute(sql) # 提交給數據庫執行命令 connect.commit()except : #回滾,以防出現錯誤 connect.rollback()connect.close()
3.5刪除數據
import mysql.connectorconnect = mysql.connector.connect( host='127.0.0.1', # 數據庫主機地址 user='root', # 數據庫用戶名 passwd='root', # 數據庫密碼 database='test' # 要連接的數據庫)# 數據庫刪除指令sql = 'DELETE FROM `test`.`testtable` WHERE `id` = 1'# 獲取數據庫操作游標myCursor = connect.cursor()try: # 執行sql語句 myCursor.execute(sql) # 提交給數據庫執行命令 connect.commit()except : #回滾,以防出現錯誤 connect.rollback()connect.close()
4.說明
sql語句中如果有待定字符,則都可以通過
sql = 'INSERT INTO `test`.`testtable`(`id`, `name`, `age`, `address`) VALUES (%s,%s,%s,%s)'var = (1, ’windSnowLi’, 20, ’中國’)
這種方式拼接,不過執行時需要myCursor.execute(sql, var)將參數也同步傳入
到此這篇關于Python連接Mysql進行增刪改查的示例代碼的文章就介紹到這了,更多相關Python連接Mysql增刪改查內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!
相關文章:
