python的mysql鏈式操做，SQL構建器，告別原生寫法

時間 2019-11-08

標籤 python mysql 鏈式 sql 構建告別原生寫法欄目 Python 简体版

原文原文鏈接

前言

Python的mysql鏈式操做，ABuilder告別繁瑣的模型定義，節省開發時間，幾乎沒有任何要求，導入直接使用。與常規模型不一樣ABuilder不須要預先定義表字段、字段類型、字段長度等繁瑣的設置，固然那樣作有它的優勢這裏就不說了～，各具所長取捨看我的。ABuilder支持入直接使用，簡單、快速、便捷python

github地址

github.com/lizhenggan/…mysql

快速開始

安裝 a-sqlbuilder

pip install a-sqlbuilder
複製代碼

設置數據配置文件（參照數據庫配置文件說明）
開始使用

from ABuilder.ABuilder import ABuilder

model = ABuilder()
data = model.table('tar_user').field("username,id").where({"username": ["like", "%M-萌%"]}).limit(0, 1).query()
複製代碼

使用文檔

第三方庫要求

pymysql
logging

數據庫配置文件

咱們須要開發者在項目更目錄中加入database.py 數據庫配置文件git

確保from database import database能獲取到數據庫配置項github

配置文件實例:sql

class Config(object):
    pass

class Proconfig(Config):
    pass


class Devconfig(Config):
    debug = True
    DATABASE_URI = 'mysql+pymysql://root:root@127.0.0.1:3306/target'
    data_host = '127.0.0.1' 
    data_pass = 'root'
    data_user = 'root'
    database = 'target'
    data_port = 3306
    charset = 'utf8mb4'


database = Devconfig
複製代碼

支持函數

目前項目只支持一些簡單用法具體以下數據庫

table 查詢表
where where條件
where_or 設置or條件
field 查詢字段
limit 查詢條數
group 分組
order 排序
join 連表查詢
first 查詢單條
query 查詢多條
pluck 查詢單個字段
insert 插入
update 修改
delete 刪除
select 執行原生查詢
commit 事物提交
rollback 事物回滾
get_last_sql 獲取執行sql
get_insert_id 獲取插入id

table

設置查詢表函數

from ABuilder.ABuilder import ABuilder
data = ABuilder().table('user').limit(0,1).query()
print(data)
複製代碼

where

設置where條件工具

from Amo.ABuilder import ABuilder
ABuilder().table('user').where({"id":["=",3]}).first()
複製代碼

多個where條件優化

ABuilder().table('user').where({"id":['<=',10],"sex":["=","男"]}).query()
# 或則多個where拼接
ABuilder().table('user').where({"id":['<=',10]}).where({"sex":["=","男"]}).query()
複製代碼

比較符號支持 =,<>,<,>,<=,>=,in,like等ui

where_or

設置or條件 where_or使用方法與where大同小異

from Amo.ABuilder import ABuilder
ABuilder().table('user').where_or({"id":["=",3]}).query()
複製代碼

比較符號支持 =,<>,<,>,<=,>=,in,like等

field

設置查詢字段

ABuilder().table("user").field("user_id,sex,user_name").query()
# 舉例count使用
ABuilder().table("user").field("count(*) as count").query()
複製代碼

不設置field默認查詢所有字段 *,查詢字段使用,隔開,支持count(),sum()等

注意：不支持相似DATE_FORMAT(NOW(),'%m-%d-%Y')這類帶有%的函數

limit

查詢數

ABuilder().table("user").limit(0,10).query()
複製代碼

limit 第一個參數爲開始查詢位置，第二個參數爲獲取多少條

group

分組

# 按照性別分組
ABuilder().table("user").field("count(*) as count").group('sex').query()

# 多個分組使用
ABuilder().table("user").field("count(*) as count").group('sex').group('age').query()
# sql爲：select count(*) as count from user group by sex,age
複製代碼

order

排序

ABuilder().table("user").order("user_id","desc").query()

# 多個排序值
ABuilder().table("user").order("user_id","desc").order("sex",'asc').query()
# sql爲：select * from tar_user order by user_id desc,sex asc
複製代碼

order by前後順序：遵循從左到右

join

連表查

ABuilder().table('user as u').field('u.id,b.name').join('book b', 'u.id=b.user_id','INNER').where({"u.id": ['=', 1]}).query()

# sql爲：select u.id,b.name from user as u INNER JOIN book b on u.id=b.user_id where u.id = 1
複製代碼

join三個參數說明

表名
列表條件支持 and,or
join類型：INNER,LEFT,RIGHT,FULL 默認INNER

支持多個連表，拼接多個join便可。例如:table('table as t').join('table1 t1','t1.user_id=t.id').join('table2 t2','t1.id=t2.book_id')

first

查詢單條記錄

find = ABuilder().table('user').where({"id":["=",3]}).first()
print(find)
複製代碼

query

查詢多條記錄

data = ABuilder().table('user').where({"id":["in",(1,2,3,4)]}).query()
print(data)
複製代碼

pluck

查詢單個字段

user_id = ABuilder().table('user').where({"username":["=",'張三']}).pluck('id')
print(user_id)
複製代碼

insert

插入數據

model = ABuilder()
state = model.table("user").insert({"username":"張三","sex":'男',"age":18})
if state:
    print("添加成功！自增id：%" % model.get_insert_id)
else:
    print("添加失敗")
複製代碼

update

修改記錄

state = ABuilder().table("user").where({"username":["=","張三"]}).update({"age":25})
if state:
    print('修改爲功')
else:
    print('修改失敗')

複製代碼

delete

刪除記錄

state = ABuilder().table("user").where({"username":["=","張三"]}).delete()
if state:
    print('刪除成功')
else:
    print('刪除失敗')
複製代碼

select

執行原生sql

model = ABuilder()
# 第一種方式
model.select("SELECT username,id FROM user where id=%s", [1])
# 第二種方式
model.select("SELECT username,id FROM user where id=1")
複製代碼

commit，rollback

事物操做

model = ABuilder()
state = model.table("user").insert({"username":"張三","sex":'男',"age":18})
if state:
    state = model.table("book").insert({"book_name":'書本暱稱',"user_id":model.get_insert_id})
if state:
    # 成功則提交事物
    model.commit()
else:
    # 失敗則回滾事物
    model.rollback()
複製代碼

操做事物注意事項：請勿實例多個ABuilder不然一部分事物在回滾操做時回滾失敗

def fun1():
    model = ABuilder()
    state = model.table("user").insert({"username":"張三","sex":'男',"age":18})
    if state:
        state = fun2()
   
    if state:
        model.commit()
    else:
        model.rollback()

def fun2():
    model = ABuilder()
    return  model.table("book").insert({"book_name":'書本暱稱',"user_id":model.get_insert_id})

fun1()
複製代碼

這樣若是fun2()返回失敗的是失敗狀態回滾的只是fun1()執行的sql卻沒法回滾fun2()執行的sql，正確作法以下：

def fun1():
    model = ABuilder()
    state = model.table("user").insert({"username":"張三","sex":'男',"age":18})
    if state:
        state = fun2(model)
   
    if state:
        model.commit()
    else:
        model.rollback()

def fun2(model):
    return  model.table("book").insert({"book_name":'書本暱稱',"user_id":model.get_insert_id})

fun1()
複製代碼

get_last_sql

獲取最後一條執行sql

model = ABuilder()
 find = model.table('user').where({"id":["=",3]}).first()
 print(model.get_last_sql)
複製代碼

獲取sql注意事項：輸出的sql對於字符串沒有加上引號，致使拷貝到數據庫管理工具裏沒法執行，處理辦法：給予字符串加上單引號或雙引號便可，後面維護會優化（抱歉）

get_insert_id

獲取插入自增id

model = ABuilder()
model.table("user").insert({"username":"張三","sex":'男',"age":18})
print(model.get_insert_id)
複製代碼

class繼承方式使用示例

from ABuilder.ABuilder import ABuilder
class UserModel(ABuilder):

    def __init__(self):
        self.table_name = 'user'
        
    def user_info(self,user_id):
        info = self.table(self.table_name).field("user_id,user_name").where({"user_id":user_id}).first()
        print(self.get_last_sql)
        return info
        
    def login(self):
        pass
        
userInfo = UserModel().user_info(user_id=1)
print(userInfo)
複製代碼