LoggingQuerySql

[jackiect]

class LoggingQuerySql:
    def __init__(self, logger_dot_level, extra_msg=""):
        self.logger_dot_level = logger_dot_level
        self.extra_msg = extra_msg

    def __call__(self, sql, param):
        for i in range(0, len(params)):
            params[i] = "'%s'" % params[i]
        self.logger_dot_level("%s%s;", self.extra_msg, sql % tuple(param))

[jackiect]

• select(F.ari__account_id, distinct=True, view_exec_query=LoggingSql(stat_log.debug, "get_reg_m_ids:"))
• count(F.id, view_exec_query=LoggingSql(stat_log.info, "new_m_recruiting:"))
• select_one("COUNT(*) as total", view_exec_query=LoggingSql(stat_log.debug, "absent_record:")).total

[jackiect]

以count为例

    @opt_checker(["distinct", "for_update", "view_exec_query"])
    def count(self, *f_list, **opt):
        # ............
        view_exec_query = opt.get("view_exec_query")
        if callable(view_exec_query):
            view_exec_query(sql, params)

        if self._db is None:
            return sql, params
        # ............