Объект SQLAlchemy, уже прикрепленный к сеансу
Я пытаюсь получить сервер для работы приложения, но я получаю сообщение об ошибке при входе в систему:
[!] Object '<User at 0x7f12bc185a90>' is already attached to session '2' (this is '3')
Кажется, что сеанс, который я добавляю, уже находится в базе данных. Это фрагмент кода, вызывающий проблему:
@app.route('/login', methods=['POST'])
def login():
u = User.query.filter(User.username == request.form["username"]).first()
if not u or u.password != request.form["password"]:
return error("E1")
s = Session.get_by_user(u)
if s is not None:
db_session.delete(s)
db_session.commit()
print db_session.execute("SELECT * FROM sessions").fetchall()
s = Session(u)
db_session.add(s)
db_session.commit()
return jsonify(s.values)
Как вы можете видеть, я печатаю содержимое из таблицы сеансов, прежде чем пытаться что-то добавить, и он пуст! ([])
Что еще может быть причиной этого?
Вот реализация "Session":
class Session(Base):
__tablename__ = "sessions"
id = Column(Integer, primary_key=True)
user_id = Column(Integer, ForeignKey('users.id'), unique=True)
user = relationship(User)
key = Column(String(50), unique=True)
created = Column(DateTime)
def __init__(self, user=None):
self.user = user
self.key = base64.encodestring(os.urandom(24)).strip()
self.created = datetime.now()
def __repr__(self):
return '<Session %r>' % (self.key)
@property
def values(self):
return {"username" : self.user.username,
"key" : self.key,
"created" : str(self.created),
}
@classmethod
def get_by_key(cls, key):
s = cls.query.filter(cls.key == key).first()
#print datetime.now() - s.created
if s and datetime.now() - s.created > settings.SESSION_LIFETIME:
s = None
return s
@classmethod
def get_by_user(cls, user):
s = cls.query.filter(cls.user == user).first()
if s and datetime.now() - s.created > settings.SESSION_LIFETIME:
s.query.delete()
db_session.commit()
s = None
return s
Ответы
Ответ 1
Объект, который вы пытаетесь изменить, уже прикреплен к другому сеансу.
Возможно, у вас неправильный импорт, а db_session - это новый экземпляр.
Хорошим обходным путем для этого является извлечение текущего связанного сеанса и его использование:
Вместо:
db_session.add(s)
делать:
current_db_sessions = db_session.object_session(s)
current_db_sessions.add(s)
Ответ 2
Как упомянул @marcinkuzminski, вы не можете добавить объект, который уже присоединен к другому сеансу. Простое извлечение исходного сеанса из объекта с помощью object_session()
рискованно, хотя, если вы не уверены, что сеанс возник в том же контексте потока, в котором вы в данный момент работаете. Потокобезопасным методом является использование merge():
local_object = db_session.merge(original_object)
db_session.add(local_object)
db_session.commit()
Ответ 3
Эта проблема с сеансом db возникает, если у вас есть server.py и model.py, импортирующие друг друга
server.py
from flask import Flask
import os
import models as appmod #################### importing models here in server.py<----------
app = Flask(__name__) # L1
app.config.from_object(os.environ['APP_SETTINGS']) # L2
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False # L3
database = SQLAlchemy(app) # L4
db = database # L5
@app.route('/item_delete/<id>', methods=['DELETE'])
def remove_method(id = None):
data_rec = appmod.Employee.query.get(id)
db.session.delete(data_rec)
db.session.commit()
return "DELETE"
if __name__ == '__main__':
app.run(port=5000, host='0.0.0.0',debug=True,threaded=True)
models.py
from server import db #################### importing server in models.py here <------------
from sqlalchemy.dialects.mysql import JSON
class Employee(db.Model):
__tablename__ = 'employe_flask'
id = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(128))
datetime = db.Column(db.DateTime)
designation = db.Column(db.String(128))
def __init__(self, name, datetime, designation):
self.name = name
self.datetime = datetime
self.designation = designation
@staticmethod
def delete_rec(data_rec):
db.session.delete(data_rec)#.delete
db.session.commit()
def __repr__(self):
record = {"name":self.name,"date":self.datetime.ctime(),"designation":self.designation}.__str__()
return record
Удалите строку L1-L5 с сервера .py и поместите ее в общий файл, например settings.py
и импортировать 'app' и 'db' в server.py и импортировать db в models.py
как эти файлы ниже
server.py
from flask import Flask
import os
import models as appmod
from settings import app, db
@app.route('/item_delete/<id>', methods=['DELETE'])
def remove_method(id = None):
data_rec = appmod.Employee.query.get(id)
db.session.delete(data_rec)
db.session.commit()
return "DELETE"
if __name__ == '__main__':
app.run(port=5000, host='0.0.0.0',debug=True,threaded=True)
settings.py
import os
from flask import Flask
from flask.ext.sqlalchemy import SQLAlchemy
app = Flask(__name__) # L1
app.config.from_object(os.environ['APP_SETTINGS']) # L2
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False # L3
database = SQLAlchemy(app) # L4
db = database # L5
models.py
from settings import db
from sqlalchemy.dialects.mysql import JSON
class Employee(db.Model):
__tablename__ = 'employe_flask'
id = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(128))
datetime = db.Column(db.DateTime)
designation = db.Column(db.String(128))
def __init__(self, name, datetime, designation):
self.name = name
self.datetime = datetime
self.designation = designation
@staticmethod
def delete_rec(data_rec):
db.session.delete(data_rec)#.delete
db.session.commit()
def __repr__(self):
record = {"name":self.name,"date":self.datetime.ctime(),"designation":self.designation}.__str__()
return record
Ответ 4
У меня тоже есть эта проблема. Я просто создал test_file.py и добавил код:
from app import app
from models import Tovar
from flask_sqlalchemy import SQLAlchemy
db = SQLAlchemy(app)
tovardel = Tovar.query.filter(Tovar.region == 1 and Tovar.price == 12).first()
db.session.delete(tovardel)
tovar = Tovar.query.filter(Tovar.region == 1 and Tovar.price == 12).first()
print(tovar.description)
когда я запускаю код
Object '<Tovar at 0x7f09cbf74208>' is already attached to session '1' (this is '2')
ПРОБЛЕВНОЕ РЕШЕНИЕ:
Если у вас есть db = SQLAlchemy(app)
, например, в text_file.py, и в app.py, у вас постоянно возникает эта проблема. Вы должны del db = SQLAlchemy(app)
и импортировать базу данных из приложения from app import db