0

我有一个将 sqlalchemy 绑定到 postgres 数据库的烧瓶。所有组件都使用功能齐全的读取。我有一个简单的模型：

class School(db.Model):
    __tablename__ = 'schools'
    id = db.Column(db.Integer, db.Sequence('schools_id_seq'), primary_key=True)
    name = db.Column(db.String(80))
    active = db.Column(db.Boolean)
    created = db.Column(db.DateTime)
    updated = db.Column(db.DateTime)

    def __init__(self, name, active, created, updated):
        self.name = name
        self.active = active
        self.created = created
        self.updated = updated

在 postgres 表上工作：

CREATE SEQUENCE schools_id_seq;

CREATE TABLE schools(
  id  int   PRIMARY KEY NOT NULL DEFAULT nextval('schools_id_seq'),
  name  varchar(80) NOT NULL,
  active boolean DEFAULT TRUE,
  created timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
  updated timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP
);

ALTER SEQUENCE schools_id_seq OWNED BY schools.id;

当我从 psql 对该表进行插入操作时，一切都很好：

cake=# select nextval('schools_id_seq');
 nextval 
---------
      65
(1 row)

cake=# INSERT INTO schools (id, name, active, created, updated) VALUES (nextval('schools_id_seq'),'Test', True, current_timestamp, current_timestamp);
INSERT 0 1

导致：

66 | Test                           |          0 | t      | 2016-08-25 14:12:24.928456 | 2016-08-25 14:12:24.928456

但是当我尝试从烧瓶中插入相同的插入时，堆栈跟踪抱怨重复id，但它nextval用于获取该值：

sqlalchemy.exc.IntegrityError：（psycopg2.IntegrityError）重复键值违反唯一约束“schools_pkey”详细信息：键（id）=（7）已经存在。[SQL：“插入学校（ID，名称，活动，创建，更新）值（nextval（'schools_id_seq'），％（名称）s，％（活动）s，％（创建）s，％（更新）s ) 返回学校.id"] [参数: {'active': True, 'name': 'Testomg', 'updated': datetime.datetime(2016, 8, 25, 14, 10, 5, 703471), 'created ': datetime.datetime(2016, 8, 25, 14, 10, 5, 703458)}]

为什么 sqlalchemy 调用nextval不会返回与 postgres db 中的相同调用产生的相同的下一个 val？

更新：@RazerM 告诉我关于 echo=true 参数，我不知道。和

app.config['SQLALCHEMY_ECHO']=True

我从一个新的插入中产生了（请注意，在这个尝试中，它10应该是fetched 67）：

2016-08-25 14:47:40,127 INFO sqlalchemy.engine.base.Engine select version()
2016-08-25 14:47:40,128 INFO sqlalchemy.engine.base.Engine {}
2016-08-25 14:47:40,314 INFO sqlalchemy.engine.base.Engine select current_schema()
2016-08-25 14:47:40,315 INFO sqlalchemy.engine.base.Engine {}
2016-08-25 14:47:40,499 INFO sqlalchemy.engine.base.Engine SELECT CAST('test plain returns' AS VARCHAR(60)) AS anon_1
2016-08-25 14:47:40,499 INFO sqlalchemy.engine.base.Engine {}
2016-08-25 14:47:40,594 INFO sqlalchemy.engine.base.Engine SELECT CAST('test unicode returns' AS VARCHAR(60)) AS anon_1
2016-08-25 14:47:40,594 INFO sqlalchemy.engine.base.Engine {}
2016-08-25 14:47:40,780 INFO sqlalchemy.engine.base.Engine show standard_conforming_strings
2016-08-25 14:47:40,780 INFO sqlalchemy.engine.base.Engine {}
2016-08-25 14:47:40,969 INFO sqlalchemy.engine.base.Engine BEGIN (implicit)
2016-08-25 14:47:40,971 INFO sqlalchemy.engine.base.Engine INSERT INTO schools (id, name, active, created, updated) VALUES (nextval('schools_id_seq'), %(name)s, %(active)s, %(created)s, %(updated)s) RETURNING schools.id
2016-08-25 14:47:40,971 INFO sqlalchemy.engine.base.Engine {'name': 'Testing', 'created': datetime.datetime(2016, 8, 25, 14, 47, 38, 785031), 'active': True, 'updated': datetime.datetime(2016, 8, 25, 14, 47, 38, 785050)}
2016-08-25 14:47:41,064 INFO sqlalchemy.engine.base.Engine ROLLBACK

sqlalchemy.exc.IntegrityError：（psycopg2.IntegrityError）重复键值违反唯一约束“schools_pkey”详细信息：键（id）=（10）已经存在。[SQL：“插入学校（ID，名称，活动，创建，更新）值（nextval（'schools_id_seq'），％（名称）s，％（活动）s，％（创建）s，％（更新）s ) 返回学校.id"] [参数: {'updated': datetime.datetime(2016, 8, 25, 14, 54, 18, 262873), 'created': datetime.datetime(2016, 8, 25, 14, 54, 18, 262864), 'active': True, 'name': 'Testing'}]

4

2 回答 2

0

序列总是递增的，因此您的 select 语句和 SQLAlchemy 都会递增该值。

如序列操作函数中所述：

将序列对象推进到下一个值并返回该值。这是以原子方式完成的：即使多个会话同时执行 nextval，每个会话都将安全地接收到不同的序列值。

如果使用默认参数创建了序列对象，则连续调用 nextval 将返回从 1 开始的连续值。其他行为可以通过使用CREATE SEQUENCE命令中的特殊参数来获得；有关更多信息，请参阅其命令参考页面。

重要提示：为避免阻塞从同一序列中获取数字的并发事务，nextval 操作永远不会回滚；也就是说，一旦获取了一个值，它就被认为是已使用的，并且不会再次返回。即使周围的事务稍后中止，或者调用查询最终没有使用该值也是如此。例如，带有 ON CONFLICT 子句的 INSERT 将计算要插入的元组，包括执行任何所需的 nextval 调用，然后检测任何可能导致其遵循 ON CONFLICT 规则的冲突。这种情况会在赋值序列中留下未使用的“漏洞”。因此，PostgreSQL 序列对象不能用于获得“无间隙”序列。

于 2016-08-25T21:30:06.543 回答
0

好吧，在这种情况下，解决方案很简单，它没有解释为什么，因为我认为我们应该查看整个环境，您无法向我们展示，否则会花费太长时间。所以尝试插入尽可能多的记录，因为它将达到 67 并且下一个插入应该应用而没有任何错误，因为序列最小值将达到适当的值。当然，您可以尝试先向属性添加server_default选项：id

 server_default=db.Sequence('schools_id_seq').next_value()

所以

seq = db.Sequence('schools_id_seq')

在课堂上：

id = db.Column(db.Integer, seq, server_default=seq.next_value(), primary_key=True)

Sqlalchemy 以这种方式提到了这一点：

Sequence 最初旨在成为 Python 端的指令，因此以这种方式指定它可能也是一个好主意。

于 2016-08-26T06:31:37.053 回答