幾個知識點
cur.execute()返回值是影響條數
fetchone()是取結果集中的第一條,所以多條裡取一條記得讓目標資料在第一條才能用這個方法
fetchmany() 讀取多條
fetchall()獲取全部資料
cursor.rownumber 獲取當前游標位置
cursor.scroll(2,mode='relative')將游標前移2個位置
conn.rollback()回滾事務 -->事務回滾需要在關閉游標之前執行
__author__ = 'kangpc'
__date__ = '2021-12-31 9:10'
import pymysql,random,time
class makedb:
def __init__(self):
# 連線引數
self.host = "10.11.22.33"
self.port = 3306
self.user = "root"
self.passwd = "123456"
self.database = "finance"
def open_conn(self):
self.conn = pymysql.connect(
host = self.host,
port = self.port,
user = self.user,
password = self.passwd,
database = self.database,
charset = 'utf8'
) def insert(self,sql, purchase_order,account_period):
try:
cur = self.conn.cursor()
result = cur.execute(sql,(purchase_order,account_period))
except exception as e:
print("----執行sql報錯,錯誤資訊----")
raise e
finally:
cur.close()
self.conn.commit()
self.conn.close()
return result
def update(self,sql):
try:
cur = self.conn.cursor()
result = cur.execute(sql)
except exception as e:
print("----執行sql報錯,錯誤資訊----")
raise e
finally:
cur.close()
self.conn.commit()
self.conn.close()
return result
def select(self,sql):
try:
cur = self.conn.cursor()
cur.execute(sql)
except exception as e:
print("----執行sql報錯,錯誤資訊----")
raise e
finally:
cur.close()
self.conn.commit()
self.conn.close()
return cur.fetchone()
if __name__ == '__main__':
# 在fin_order插入收貨單
sql1 = "insert into finance.fin_order...."
# 查詢fin_order未對賬的最小id
sql2 = "select min(id) from fin_order....."
# 批量更新彙總單為未對賬的狀態
sql3 = "update fin_order .........."
db = makedb()
conn = db.open_conn()
db.select(sql2)
quartz動態增傷改查任務實現
下面這篇是新增引數的 框架是我自己搭的，springboot mybatisplus fastjson quartz的 全部來自上面的兩篇部落格 需要注意的幾點 首先，先搭建好springboot專案，然後參照博主的部落格內容，1.都寫對，註解別忘了加 2.其中quartz的8個表要建立好 3.把q...
C 實現順序表基本函式以及增刪查改
下面的 是我們用c 實現的順序表，其中頭插頭刪，尾插尾刪函式可以復用insert函式，和erase函式。include include include using namespace std typedef int datatype class seqlist seqlist const seqli...
Java實現對mysql資料庫的增刪查改
前面我們已經講過如何實現對mysql資料庫的連線。最簡單的資料庫操作就是增刪查改。其實對懂得實現對資料庫的連線，其餘的，對於一些簡單的操作都是很簡單的。檢視資料 public static void show info throws classnotfoundexception,sqlexcepti...