python運算元據庫指令碼

import pymysql

class operationmysql:

"""資料庫sql相關操作

import pymysql

db = pymysql.connect("localhost","testuser","test123","testdb" )

cursor = db.cursor()

cursor.execute("select version()")

"""

def __init__(self):

# 建立乙個連線資料庫的物件
self.conn = pymysql.connect(
host='127.0.0.1', # 連線的資料庫伺服器主機名
port=3306, # 資料庫埠號
user='test', # 資料庫登入使用者名稱
passwd='111111',
db='test', # 資料庫名稱
charset='utf8', # 連線編碼
cursorclass=pymysql.cursors.dictcursor
)# 使用cursor()方法建立乙個游標物件，用於運算元據庫
self.cur = self.conn.cursor()
# 查詢一條資料
def search_one(self, sql):
self.cur.execute(sql)
result = self.cur.fetchone() # 使用 fetchone()方法獲取單條資料.只顯示一行結果
# result = self.cur.fetchall() # 顯示所有結果
return result
# 更新sql
def updata_one(self, sql):
try:
self.cur.execute(sql) # 執行sql
self.conn.commit() # 增刪改操作完資料庫後，需要執行提交操作
except:
# 發生錯誤時回滾
self.conn.rollback()
self.conn.close() # 記得關閉資料庫連線
# 插入sql
def insert_one(self, sql):
try:
self.cur.execute(sql) # 執行sql
self.conn.commit() # 增刪改操作完資料庫後，需要執行提交操作
except:
# 發生錯誤時回滾
self.conn.rollback()
self.conn.close()
# 刪除sql
def delete_one(self, sql):
try:
self.cur.execute(sql) # 執行sql
self.conn.commit() # 增刪改操作完資料庫後，需要執行提交操作
except:
# 發生錯誤時回滾
self.conn.rollback()
self.conn.close()

op_mysql = operationmysql()

res = op_mysql.search_one("select * from odi_order where order_no='12222'")

print(res)

python運算元據庫

資料庫的操作在現在的python裡面已經變得十分的好用,有了一套api標準.下面的就是講講如何的去使用這套框架定義.此框架包含以下部分 connect parameters.其中的引數格式如下 dsn 資料來源名稱 user 使用者名稱 可選 password 密碼 可選 host 主機名 可選 d...

python 運算元據庫

目的 通過excel定義檢查指標項，然後通過python讀取指標，通過oracle sqlplus工具去執行獲取具體巡檢結果。unicode utf 8 coding utf 8 import os import sys import xlrd import paramiko reload sys ...

python運算元據庫

python運算元據庫都是通過資料庫驅動取操作的。現在主要有兩張，一種是通過pymysql，還有一種是通過sqlalchemy。在這裡可能還會有人說還有mysqldb模組也可以操作。確實是的，但是mysqldb對python3已經不支援了，所以這裡我就不討論了。第一種pymysql pymysql幫...