1.在项目的web目录下的py文件通过定义接口KgcmsApi类，就可以直接调用self.db来操作数据库。 　　

class KgcmsApi(object):
    """产品模块类"""
 
    def __init__(self):
        """初始化数据"""
        pass
     
    def __call__(self):
        """接口文件"""
        return self.db.__doc__

　　2.在项目的kyger目录中的模块如果需要操作数据库，需要在web目录下的py文件中将self.db做为参数传递： 　　

# 文件目录：web/article.py。 创建实例article时将self.db当做参数传递。
class KgcmsApi(object):
    """KGCMS框架接口"""
 
    def __init__(self):
        pass
 
    def __call__(self):
        from kyger.article import Article
        article = Article(self.db)
        return 0

　　

# 文件目录：kyger/article.py
class Article(object):
    """文章调用"""
    # 构造函数
    def __init__(self, db=None):
        # 如果创建实例时将db传递过来则直接赋值给self.db使用，如果没有则需要创建
        from kyger.db import MySQL
        self.db = db if db else MySQL()  # 防止因为没有传递self.db导致操作数据库出错

　　描述：往指定的表里插入数据，SQL语句：INSERT INTO `kgcms`.`kg_admin` (`id` ,`username`) VALUES (NULL , 'kyger'),。

　　

add(table, data, log=True)

　　table [str]：表名，不包含前缀。
　　data [str]：要插入的数据字典，对应的字段名及值: {'id':'NULL','username':'kyger'}。
　　log [bool]：是否记录操作日志, 一般情况下建议开启。


　　log [bool]：返回一个字符串或0。

　　

data = {
   'username': 'admin',
   'password': '123456',
   'encryption': 0,
}
return self.db.add('admin', data)  # 往admin表中添加数据

　　

'23'  # 返回插入数据的id

　　描述：删除数据操作，SQL语句：DELETE FROM `kg_admin` WHERE `kg_admin`. `id` = 20;。

　　

dele(table, where, limit=0, log=True)

　　table [str]：表名，不包含前缀。
　　where [int|str]：条件, 如果int类型将视为id；其它视为条件语句: 20|`username` = 'kyger' && ...
　　　不支持删除全部，但可使用条件 1=1 达到删除部分数据。
　　limit [int]：删除的记录条数。
　　log [bool]：是否记录操作日志, 建议开启。


　　返回一个int类型数据。

　　

return self.db.dele('article', 14)

　　

return self.db.dele('article', '`id` >13')

　　

1  # 返回删除的数据条数

　　描述：修改/更新数据，SQL语句：UPDATE `kg_admin` SET `password` = '999' WHERE `kg_admin`.`id` = 2;。

edit(table, data, where=None, limit=0, log=True)

　　table [str]：表名，不包含前缀。
　　data [dict]：要修改的字段名及值：{'username':'kyger', 'password': '123456'}。
　　where [int|str]：条件，如果是一个数字将视为id；为0时忽略条件，将更新所有记录; 其它视为条件语句:：20|`username` = 'kyger' && ...。
　　limit [int]：影响的记录数，0时不限制。
　　log [bool]：是否记录操作日志, 建议开启。


　　返回一个int类型数据。

　　

return self.db.edit('admin', {'username':'kyger', 'password': '123456'}, 5, 1)

　　

1  # 返回影响的数据条数

　　描述：获取数据表里所有的字段名属性。

　　

field_list(table, log=True)

　　table [str]：表名，不包含前缀。
　　log [bool]：是否记录操作日志, 建议开启。


　　返回一个列表。

　　

return self.db.field_list('test')

　　

# 获取数据表里所有的字段名和属性
[{'Field': 'id', 'Type': 'int(11) unsigned', 'Null': 'NO', 'Key': '', 'Default': None, 'Extra': ''}, {'Field': 'test', 'Type': 'int(11) unsigned zerofill', 'Null': 'NO', 'Key': '', 'Default': None, 'Extra': ''}]

　　描述：获取上一步 INSERT 操作产生的ID。

　　

lastrowid()

　　无参数。

　　

return self.db.lastrowid()

　　

5  # 上一次插入数据的id

　　描述：查询数据，查询中所有的表名前缀使用{pr}代替。

　　

list(table, field='*', where=0, order=0, page=0, limit=30, shift=0, log=False)

　　table [str]：表名，form语句，或多表关联，前缀使用 {pr} 代替，单个表名时不需要加前缀。
　　field [str]：查询的字段，默认为 *。
　　where [str]：条件语句, 如果是一个 int 值,则自动转化为:WHERE `id` = "%s"'。
　　order [str]：排序：`id` ASC, `name` DESC。
　　page [int]：当前页码，是否分页，0不分页；其它数字为页码；分页时可以通过 total 获取总记录数。
　　limit [int|str]：分页时只填写一个数字，每页要显示的记录数: '0, 30'|10。
　　shitf [int]：是否将二维列表成一维，1转成一维、0不转换，查询单条记录时非常有用。
　　log [bool]：是否记录操作日志, 查询敏感数据时建议开启。


　　log [bool]：返回一个列表。

　　

return self.db.list(
    table='`{pr}admin` as a',
    field='a.`id`, a.`username`',
    where='`id`>4 && `id`<100',
    order='`id` ASC, `username` DESC',
    page=2,
    limit=3,
    log=True,
)

　　

[{'id': 90, 'username': 'admin'}, {'id': 92, 'username': 'kgcms888'}, {'id': 93, 'username': 'kgcms2'}]

　　描述：获取数据库操作日志记录。

　　

log(type=1, info={'state': 'SUCCESS'})

　　type [int]：日志类型(1查询敏感数据/2添加数据/3修改数据/4删除数据/5其它数据库操作/6后台管理员登录/7上传文件)。
　　info [dict]：MySQL json。state: [SUCCESS|FAILURE] 结果。


　　无返回值。

　　

return self.db.log(type=5, info={'state': 'SUCCESS'})

　　

# 暂无结果

　　描述：查询当前对应的 MySQL 帐户运行的线程,查看MySQL连接列表。

　　

processlist()

　　无参数


　　返回一个列表。

return self.db.processlist()

[{'Id': 72535, 'User': 'kgcms', 'Host': '163.179.46.37:63341', 'db': 'kgcms', 'Command': 'Query', 'Time': 0, 'State': 'starting', 'Info': 'SHOW FULL PROCESSLIST'}]

　　描述：自定义查询, 直接查询SQL。

　　

run_sql(sql, act='list', log=True)

　　sql [str]：要执行的sql语句。
　　act [str]：add：返回插入后的ID，list：返回list数据，act=edit|dele：返回影响的数据条数。
　　act [str]：log [bool]：是否记录操作日志, 建议开启。


　　返回一个列表。

　　

return self.db.run_sql('select id,username from kg_admin where id=83', 'list')

　　

return self.db.run_sql('insert into kg_admin(id,username) value(100,"kgtest")', 'add')

　　

return self.db.run_sql('update kg_admin set username="kg" where id=100', 'edit')

　　

return self.db.run_sql('delete from kg_admin where id=100', 'dele') 

　　

[{'id': 83, 'username': 'kgcms'}]

　　

100  # 返回插入的id

　　

1  # 返回影响的条数

　　

1  # 返回影响的条数

　　描述：获取当前库中所有的数据表表名。

　　

table_list(log=True)

　　log [bool]：是否记录操作日志, 建议开启。


　　返回一个列表。

　　

return self.db.table_list()

　　

['kg_ad', 'kg_admin', 'kg_article', 'kg_category', 'kg_guestbook']

　　描述：获取MySQL自动断开连接时效。

　　

timeout()

　　无参数。


　　返回一个字典。

　　

return self.db.timeout()

　　

{'Variable_name': 'connect_timeout', 'Value': '10'}

　　描述：获取MySQL版本号。

　　

version()

　　无参数。


　　返回一个字符串。

　　

return self.db.version()

　　

'5.7.24'

　　

'5.7.24'

　　描述：关闭数据库连接。

　　

close()

　　无参数。


　　返回布尔类型或字符串。

　　

return self.db.close()

　　

'tools.pymysql.err.Error: Already closed'

　　1. total_rows：查询到的总记录条数 　　

self.db.total_rows  # 调用总记录条数

　　2. total_page：查询到的总页数 　　

self.db.total_page  # 调用总页数

　　3. sql：查询的sql语句 　　

self.db.sql  # 调用执行的sql语句

　　4. request_count：当前页请求数据库的次数，包括查询、修改、添加数据的总次数 　　

self.db.request_count  # 调用当前页面请求数据库的次数数

　　5. page：查询的当前页码 　　

self.db.page  # 调用当前页码

　　v1.0.1