使用sqlalchemy为clickhouse创建数据表

安装需要的包

1	$ pip install clickhouse-sqlalchemy

使用demo

# -*- coding: utf-8 -*-
from sqlalchemy import create_engine, Column, MetaData, literal
from clickhouse_sqlalchemy  import Table, make_session, get_declarative_base, types, engines
uri = "clickhouse://default:Qbb4RJa4@localhost/dayday"
engine = create_engine(uri)
session = make_session(engine)
metadata = MetaData(bind=engine)
Base = get_declarative_base(metadata=metadata)
day  = Table('date',metadata,
              Column('day',types.Date,primary_key=True),
              Column('value',types.Int32,server_default=literal(1)),
              engines.Memory()
              )
if __name__ == "__main__":
        day.create()

我设置了密码，自己没有设置，@与//前面几个不用写

使用一键运行创建大量数据库表

# -*- coding: utf-8 -*-

from sqlalchemy import create_engine, Column, MetaData, literal
from clickhouse_sqlalchemy import make_session, get_declarative_base, types, engines
from datetime import datetime

uri = "clickhouse://default:Qbb4RJa4@localhost/default"

engine = create_engine(uri)
session = make_session(engine)
metadata = MetaData(bind=engine)

Base = get_declarative_base(metadata=metadata)


class User(Base):
    __tablename__ = "user"
    id = Column(types.Int8, primary_key=True)
    name = Column(types.String)
    pwd = Column(types.String)
    email = Column(types.String)
    phone = Column(types.String)
    info = Column(types.String)
    face = Column(types.String)
    addtime = Column(types.Date)
    uuid = Column(types.String)

    __table_args__ = (
        engines.Memory(),
    )

    def __repr__(self):
        return "<User %r>" % self.name


if __name__ == "__main__":
   Base.metadata.create_all(engine)