python操作mysql數據庫需要使用到mysqlclient庫。
安裝:pip install mysqlclient
python連接mysql數據庫分以下步驟:
1、與mysql建立連接;
2、獲取游標;
3、執行sql語句;
4、fetch查詢結果或commit修改結果;
5、關閉游標;
6、關閉mysql連接。
完整示例如下:
# -*- coding:utf-8 -*-
import MySQLdb
from readConfig import get_config_values
from utils.resutltodict import dict_fetchall
def execute_sql_query(sql, params):
"""
執行mysql sql查詢語句
:param sql: sql語句,變量使用%s占位
:param params: %s對應的變量,必須是元祖(tuple)
:return: queryset
"""
conn = MySQLdb.connect(host=get_config_values('mysql', 'host'), port=int(get_config_values('mysql', 'port')),
user=get_config_values('mysql', 'user'), passwd=get_config_values('mysql', 'password'),
db=get_config_values('mysql', 'database'), charset='utf8')
cursor = conn.cursor()
cursor.execute(sql, params)
qryset = dict_fetchall(cursor=cursor)
cursor.close()
conn.close()
return qryset
if __name__ == '__main__':
sql = """SELECT * FROM asset_devices where companyid_id=%s"""
params = (25,)
result = execute_sql_query(sql=sql, params=params)
print(result)
mysqlclient的詳細使用請參考官文:
https://mysqlclient.readthedocs.io/user_guide.html#functions-and-attributes
