版權(quán)聲明：自由轉(zhuǎn)載-非商用-非衍生-保持署名 | Creative Commons BY-NC-ND 3.0

最近有個(gè)ETL取數(shù)項(xiàng)目， 存儲(chǔ)端使用數(shù)據(jù)庫(kù)， 必要時(shí)候還要進(jìn)行多線(xiàn)程轉(zhuǎn)換， 而mysql 多線(xiàn)程多進(jìn)程讀寫(xiě)需要注意的地方太多， 多線(xiàn)程調(diào)試又非常麻煩。所有選擇python orm。

python 中orm模塊非常之多， 優(yōu)缺點(diǎn)也很明顯， 有功能比較全面的sqlalchemy， 也有django framework提供的ORM。 總之每個(gè)都優(yōu)點(diǎn)， 但也單來(lái)缺點(diǎn)。 如sqlalchemy功能多， 相對(duì)學(xué)習(xí)曲線(xiàn)就長(zhǎng)了。 django framework提供的models操作， 有很多django特性， 但這些特性也能帶來(lái)缺點(diǎn)。

這里有一篇博客專(zhuān)門(mén)講了python 眾多ORM的選擇,

SQLAlchemy 和其他的 ORM 框架

本篇博客， 研究的是peewee。 超級(jí)輕量的一個(gè)ORM模塊， 而且操作數(shù)據(jù)非常之簡(jiǎn)單。

根據(jù)數(shù)據(jù)庫(kù)表生成模型

:::shell
python -m pwiz -e mysql -H localhost -p3306 -uroot -Pkkd93kd  web_db > db.py

模型樣例

:::python
from peewee import *

database = MySQLDatabase('web_db', **{'host': 'localhost', 'password': 'kkd93kd  ', 'port': 3306, 'user': 'root'})

class UnknownField(object):
    pass

class BaseModel(Model):
    class Meta:
        database = database
        
class SyShieldOrder(BaseModel):
    _id = PrimaryKeyField()
    order_up_day = IntegerField(null=True)
    order_up_hours = IntegerField(null=True)
    order_up_moon = IntegerField(null=True)
    order_up_quarter = IntegerField(null=True)
    order_up_week = IntegerField(null=True)
    order_up_year = IntegerField(null=True)
    tu_shopid = CharField(null=True)

    class Meta:
        db_table = 'sy_shield_order'
class SyShieldUser(BaseModel):
    _id = PrimaryKeyField()
    tu_account = CharField(null=True)
    tu_area = CharField(null=True)
    tu_city = CharField(null=True)
    tu_commence = DateField(null=True)
    tu_contract = DateField(null=True)
    tu_cost = IntegerField(null=True)
    tu_domain = CharField(null=True)
    tu_nick = CharField(null=True)
    tu_platform = CharField(null=True)
    tu_province = CharField(null=True)
    tu_realcost = IntegerField(null=True)
    tu_shopid = CharField(null=True)
    tu_version = CharField(null=True)

    class Meta:
        db_table = 'sy_shield_user'

操作

:::python

from datetime import datetime
from src import *

database.connect()

for i in SyShieldUser.select():
    print i.tu_account
    print i.__dict__

for i in range(10):
    data = {
            'tu_account': "user_%s" % str(i),
            'tu_area': "HuaDong",
            'tu_city': "Shanghai",
            }
    print SyShildUser.create(tu_account="user", tu_area="HuaDong", tu_city="Shanghai", tu_shopid="100000%s" % str(i))