python优雅执行SQL模板语句

wptr33 2025-01-06 15:48 29 浏览

有时候python执行sql语句会存在变量，那就需要对sql语句格式化。但是如果语句非常复杂，有时候还得更改。还要去改脚本里面sql语句就显得很笨，我们可以单独把sql语句保存成另外一个文件，做完模板。在执行的时候就可以直接从这个模板读取，在格式化后再执行语句就可以了。当然最后的结果也可以保存到execl，在发送邮件给相关的人，以前我就是定时导数据给运营人员的。

代码：

import sys
import MySQLdb
import yaml
def readYml(file):
   #读取yaml文件
   with open(file) as fd:
       res = yaml.safe_load(fd)
    return res
    
def connMysql(host,user,dbpass,dbname,port=3306):
    # 建立数据库连接
    try:
        conn = MySQLdb.connect(host=host, user=user, passwd=dbpass, db=dbname, port=port, charset='utf8')
    except Exception as e:
        print(e)
        sys.exit()
    cur = conn.cursor()
    return conn, cur

def execMysql(cursor, mysqlstr):
    # 获取游数据库标.
    cursor.execute('SET time_zone = "+8:00"')
    cursor.execute(mysqlstr)
    res = cursor.fetchall()
    return res
if __name__ == "__main__":
    
    conn, cur = connMysql("192.168.0.x", "xx", "xx",
                                   "xx")
    tmpdict = readYml("mysql1.tmp")
    sqlstr = tmpdict["mysqltmp"]
    print(sqlstr)
    sqlstr = sqlstr.format(num=10) # 传入参数到sql语句
    res = execMysql(cur, sqlstr)
    print(res)

sql模板文件：

mysqll1.tmp

mysqltmp: "SELECT * FROM xhw.t_goods
          LIMIT {num};
          "

执行结果：

sql except

上一篇：一日一技:Python | PostgreSQL中的数据库管理
下一篇：SQL 公用表表达式:它们是什么、它们为何重要以及如何使用它们

python优雅执行SQL模板语句

代码：

sql模板文件：

执行结果：

相关推荐

程序员的开源月刊《HelloGitHub》第 71 期

如何将AI助手接入微信（打开ai手机助手）

SparkSQL——DataFrame的创建与使用

使用过 Redis 分布式锁么，它是什么回事?

VUE循环语句的使用(v-for)（vuefor循环的key）

HiveOs系统教程最细手把手教学（hiveos启动）

HIVE SQL基础语法（hive-sql）

《循环(for/while)》（循环while语句）

Spring Boot 概述（spring boot干嘛的）

西门子博途SCL高级语言之FOR循环（西门子博途for循环语句编程）