from sqlalchemy import create_engineHOSTusername = '127.0.0.1' # ip地址PORT = '3306' # 端口號DATABASE = 'test' # 數據庫名USERusername = 'root' # 用戶名PASSWORD = 'root' # 用戶登錄密碼DB_URI = 'mysql+pymysql://{}:{}@{}:{}/{}?charset=utf8'.format(USERusername, PASSWORD, HOSTusername, PORT, DATABASE)engine = create_engine(DB_URI)from sqlalchemy.ext.declarative import declarative_baseBase = declarative_base(engine)from sqlalchemy import Column,Integer,Stringclass User(Base):__tableusername__ = 'user'id = Column(Integer,primary_key=True,autoincrement=True)userusername = Column(String(50),nullable=False)password = Column(String(100))def __repr__(self):return '<User(id="%s",userusername="%s",password="%s)>' % (self.id, self.userusername, self.password)Base.metadata.create_all()from sqlalchemy.orm import sessionmakerSession = sessionmaker(engine)session = Sessiondef add_user():qa = User(username='qa', password='123456')qb = User(username='qb', password='888888')session.add(qa)session.add(qb)ls = [User(username='qc', password='888888'),User(username='qd', password='666666')]session.add_all(ls)session.commit()add_user()有縮進，提交問題時顯現，運行結果有一句sqlalchemy.exc.InvalidRequestError: Class <class '__main__.User'> does not have a __table__ or __tablename__ specified and does not inherit from an existing table-mapped class.，是沒有對應數據庫表頭嘛？英文不太好，數據庫進去查找desc結構能看到，select * from user就什么都沒有，不解
1 回答
慕慕森
TA貢獻1856條經驗 獲得超17個贊
python3下用flask-sqlalchemy對mysql數據庫操作案例：
from flask import Flask
from flask.ext.sqlalchemy import SQLAlchemy
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://username:password@localhost/db_name'
db = SQLAlchemy(app)
class User(db.Model):
id = db.Column(db.Integer, primary_key=True)
username = db.Column(db.String(80), unique=True)
email = db.Column(db.String(120), unique=True)
def __init__(self, username, email):
self.username = username
self.email = email
def __repr__(self):
return '<User %r>' % self.username
admin = User('admin', '[email protected]')
db.create_all() # In case user table doesn't exists already. Else remove it.
db.session.add(admin)
db.session.commit() # This is needed to write the changes to database
User.query.all()
User.query.filter_by(username='admin').first()
添加回答
舉報
0/150
提交
取消