python MySQL封裝呼叫

2021-10-08 23:12:17 字數 2732 閱讀 7609

import pymysql

from cfg.handle_ini import cfg #ini的配置檔案呼叫 呼叫方式cfg.get(『』,『』)

class heandlemysql(object):

# 建立連線

def __init__(self):

self.conn = pymysql.connect(

host=cfg.get('mysql','host'),

port=cfg.getint('mysql','port'),

user=cfg.get('mysql','user'),

password=cfg.get('mysql','password'),

database=cfg.get('mysql','database'),

charset='utf8',

cursorclass=pymysql.cursors.dictcursor

)# 建立游標

self.cur = self.conn.cursor()

#查詢一行

def select_one_row(self,sql):

self.conn.commit()

self.cur.execute(sql)

return self.cur.fetchone()

#查詢所有行

def select_all_row(self,sql):

self.conn.commit()

self.cur.execute(sql)

return self.cur.fetchall()

#按給定的值取行數

def select_assign_row(self,sql,assign_row):

self.conn.commit()

self.cur.execute(sql)

return self.cur.fetchmany(assign_row)

#輸出sql語句查詢後內容行數

def get_count(self,sql):

self.conn.commit()

return self.cur.execute(sql)

#更新def update_data(self,sql):

self.cur.execute(sql)

self.conn.commit()

#關閉def closs(self):

self.cur.close()

self.conn.close()

#呼叫時呼叫的變數

db = heandlemysql()

#測試if __name__ == '__main__':

sql = 'select * from member limit 10'

db = heandlemysql()

count = db.get_count(sql)

print('輸出結果個數',count)

one = db.select_one_row(sql)

print('輸出一行結果',one)

all = db.select_all_row(sql)

print('輸出所有結果',all)

assign = db.select_assign_row(sql,5)

print('輸出指定行數',assign)

db.closs()

#-----------------------學習時使用的,對整體無用-----------------------------

#資料庫操作步驟

# 1.連線資料庫,建立游標

# 2.執行sql語句

# 3.獲取執行的結果

# 4.關閉資料庫連線

#、建立連線

# conn = pymysql.connect(

# host='api.lemonban.com',

# port=3306, #不加引號

# user='future',

# password='123456',

# database='futureloan',

# charset='utf8',

# cursorclass=pymysql.cursors.dictcursor #把元組改到字典格式

# )

# # 建立游標

# cur = conn.cursor()

## #執行sql語句

# sql = 'select * from futureloan.`member` limit 10;'

# cur.execute(sql) #返回的是sql語句執行的行數

## #獲取sql語句執行的結果

# one = cur.fetchone() #一行一行的取值 第一行

# two = cur.fetchone() #一行一行的取值 第二行

# #獲取所有的

# all = cur.fetchall() #去所有行

# #按指定個數取值

# many = cur.fetchmany(5) #按給定的值取行數

## #關閉游標關閉資料庫連線釋放資源

# cur.close()

# conn.close()

python mysql基礎封裝

python執行mysql語句的話牽扯到的操作還挺多,簡單說每次執行一條語句需要進行資料庫連線 獲取游標 執行語句 獲取返回資料 斷開連線,如果其 錯還需要回滾游標等操作,每次都寫這麼一大串 會看起來十分冗餘,於是考慮寫乙個類來封裝上述操作。基本的mysql操作 import mysqldb 開啟資...

DLL封裝呼叫

首先需要建立乙個dll,在vs選中檔案 新建 專案 名稱為mydll 在裡面隨便寫乙個方法 public static string name li public static string number 12567032 public static string age 21 public sta...

pymysql 封裝呼叫

import pymysql class skq def init self config 建立連線 self.connection pymysql.connect config def add self,dict,table 執行sql語句 try with self.connection.cur...