sqlalchemy 连接mysql数据库_sqlalchemy metadata

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
# 创建对象的基类:
Base = declarative_base()

# 初始化数据库连接
# 当前只是“试探”一下mysql 并没有真正连接
engine = create_engine('mysql+pymysql://root:root@localhost:3306')
# 创建数据库
engine.execute("CREATE DATABASE dbname")
# 使用数据库
engine.execute("USE dbname") 
# 绑定session
session = sessionmaker(bind=engine)
session = session()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

接下来就可以定义model

注意继承自Base

class Comment(Base):
    __tablename__ = 'comment'
    id = Column(Integer, primary_key=True, autoincrement=True)
	……
1
2
3
4

紧接着创建’comment’表

Base.metadata.create_all(engine, checkfirst=True)
1

然后可以定义一些数据库封装方法

def return_all_comment():
	"""
	获取所有评论数据
	"""
1
2
3
4

所有的操作的都是基于session的
例如：

essay = session.query(Comment).filter_by(id=arg_id).first()
1

下次链接数据后要注意以下方法，当库已经存在时候，会报错

创建数据库

engine.execute("CREATE DATABASE dbname")
1

使用数据库

engine.execute("USE dbname")
1

当然接下来的连接接可以使用

create_engine('mysql+pymysql://root:root@localhost:3306/dbname')
1

可以将创建数据库封装到一个方法里，通过一个自定义标志位来区分当前你是否创建了数据库，如果有好的方法，请告知我。

不过还是通过mysql 控制台来创建更方便。

---

今日一小步，
明天一大步。