美文网首页
Python学习笔记_第十三章:数据库支持

Python学习笔记_第十三章:数据库支持

作者: 雨住多一横 | 来源:发表于2019-01-22 20:43 被阅读0次

    了解关系型数据库:http://www.sqlcourse.com
    了解python包支持的数据库:http://www.python.org/topics/database/
    关系型数据库并不是唯一的数据库,还有类似ZODB(http://wiki.zope.org/ZODB)的对象数据库、类似Metakit(http://www.equi4.com/metakit/python.html)的基于紧凑表的数据库和类似BSD DB(http://docs.python.org/lib/module-bsddb.html)的更简单的键——值数据库。

    Python的数据库编程接口

    Python中有多种关系型数据库对应的客户端模块,为了解决Python中各种数据库模块之间的兼容问题,现在已经通过了一个标准的数据库编程接口(DB API):http://python.org/peps/pep-0249.html
    下面简单介绍API,了解更多API细节可移步:http://wiki.python.org/moin/DatabaseProgramming

    全局变量

    Python DB API的模块特性

    变量名 用途
    apilevel 所用的Python DB API版本
    threadsafety 模块的线程安全等级
    paramstyle 在SQL查询中使用的参数风格

    apilevel:可能是1.0或2.0未来也可能有3.0,若不存在,则假定为1.0
    threadsafety:0~3的等级

    • 0:线程完全不共享
    • 1:线程共享,但连接不共享
    • 2:(连接共享)
    • 3:完全线程安全

    paramstyle:参数拼接方法,format:标准的字符串格式化(%s),pyformat:扩展的格式化,用于字典拼接,如%(foo)。除了Python风格,还有三种方式:qmark(?)、numeric(:1,:2,……)、named(类似于关键字参数)

    异常

    DB API中使用的异常

    连接游标

    connect函数常见参数

    参数名 描述 是否可选
    dsn 数据源名称,给出该参数表示数据库依赖
    user 用户名
    password 用户密码
    host 主机名称
    database 数据库名

    connect连接对象支持的函数

    名称 描述
    close 关闭
    commit 如果支持事务就提交挂起的事务,否则什么都不做
    rollback 回滚挂起的事务,可能不支持
    cursor 返回游标

    cursor对象方法

    名称 描述
    callproc(name[, params]) 调用name数据库的过程
    close() 关闭游标
    execute(oper[, params]) 执行SQL
    executemany(oper, pseq) 执行多个SQL
    fetchone() 对下一行操作:将其保存为序列
    fetchmany([size]) 对剩余size行操作:保存为序列的序列
    fetchall() 对剩余所有行操作:保存为序列的序列
    nextset() 调至下一个可用结果集
    setinputsize(sizes) 为参数预先定义内存区
    setoutputsize(size[, col]) 为获取的大数据值设定缓冲区尺寸

    cursor对象特性

    名称 描述
    description 描述结果列的序列,只读
    rowcount 结果列中的行数,只读
    arraysize fetchmany返回的行数,默认1

    数据特殊类型(Data、 Time等)

    SQLite和PySQLite

    多数数据库引擎安装都需要管理员权限,他们作为服务器程序运行。所以,此处选用小型数据库引擎SQLite作为示例
    从Python2.5开始,SQLite的优势是它的一个包装(PySQLite)已经被包括在标准库内,除非你是从源码编译Python

    数据库应用程序示例

    本例建立小型营养成分数据库作为示例程序,这个程序基于USDA的营养数据实验室提供的数据(http://www.ars.usda.gov/nutrientdata),由于里面有好多数据,我随便找的其中一个,链接为:https://pan.baidu.com/s/1NdSRJw_UcIe3UUr6wSbdJA 提取码:948d
    代码为如下

    import sqlite3 as sq
    import os
    conn = sq.connect('food.db')
    curs = conn.cursor()
    try:
        curs.execute('''
    CREATE TABLE FOOD(
    id TEXT PRIMARY KEY, desc TEXT, water FLOAT, kcal FLOAT, protein FLOAT, fat FLOAT, ash FLOAT, carbs FLOAT, fiber FLOAT, sugar FLOAT,
    fat1 FLOAT, ash1 FLOAT, carbs1 FLOAT, fiber1 FLOAT, sugar1 FLOAT, fat2 FLOAT, ash2 FLOAT, carbs2 FLOAT, fiber2 FLOAT, sugar2 FLOAT,
    fat3 FLOAT, ash3 FLOAT, carbs3 FLOAT, fiber3 FLOAT, sugar3 FLOAT, fat4 FLOAT, ash4 FLOAT, carbs4 FLOAT, fiber4 FLOAT, sugar4 FLOAT,
    fat5 FLOAT, ash5 FLOAT, carbs5 FLOAT, fiber5 FLOAT, sugar5 FLOAT, fat6 FLOAT, ash6 FLOAT, carbs6 FLOAT, fiber6 FLOAT, sugar6 FLOAT,
    fat7 FLOAT, ash7 FLOAT, carbs7 FLOAT, fiber7 FLOAT, sugar7 FLOAT, fat8 FLOAT, ash8 FLOAT, carbs8 FLOAT, fiber8 FLOAT, sugar8 FLOAT,
    carbs9 FLOAT, fiber9 FLOAT, sugar9 FLOAT
    
    )
    ''')
    except sq.OperationalError :
        curs.execute('DROP TABLE FOOD')
    
    def convert(value):
        if value.startswith('~'):
            return value.strip('~')
        if not value:
            value = 0
            return float(value)
    query = 'INSERT INTO food VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,' \
            ' ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)'
    for f in os.listdir('C:\Users\hcs\Desktop\sr24abbr'):
        for line in open('C:\Users\hcs\Desktop\sr24abbr\\' + f):
            data = line.split('^')
            vals = [convert(da) for da in data]
            curs.execute(query, vals)
    conn.commit()
    conn.close()
    

    测试代码:

    from __future__ import print_function
    import sqlite3 as sq
    import sys
    conn = sq.connect('food.db')
    cur = conn.cursor()
    query = 'select * from food where %s' % sys.argv[1]
    cur.execute(query)
    name = [f[0] for f in cur.description]
    for row in cur.fetchall():
        for pair in zip(name, row):
            print('%s:%s' % pair, end = ' ')
        print('\n')
    conn.commit()
    conn.close()
    

    控制台输入:

    python food_db_manager.py "id < 30 order by sugar"
    

    结果:

    D:\python_base_1>python food_db_manager.py "id < 30 order by sugar"
    id:01001 desc:BUTTER,WITH SALT water:None kcal:None protein:None fat:None ash:None carbs:None fiber:None sugar:None fat1:None ash1:None carbs1:None fiber1:None sugar1:None fat2:None ash2:None carbs2:None fiber2:None s
    ugar2:None fat3:None ash3:None carbs3:None fiber3:None sugar3:None fat4:None ash4:None carbs4:None fiber4:None sugar4:None fat5:None ash5:None carbs5:None fiber5:None sugar5:None fat6:None ash6:None carbs6:None fiber6
    :None sugar6:None fat7:None ash7:None carbs7:None fiber7:None sugar7:None fat8:None ash8:None carbs8:None fiber8:None sugar8:1 cup carbs9:None fiber9:1 tbsp sugar9:None
    
    

    在SQLite内部,所有值实际上都是字符串,一些转换和检查操作在数据库和Python API之间进行。

    相关文章

      网友评论

          本文标题:Python学习笔记_第十三章:数据库支持

          本文链接:https://www.haomeiwen.com/subject/hixrjqtx.html