Mercurial > libervia-pubsub
comparison sat_pubsub/test/test_storage.py @ 367:a772f7dac930
backend, storage(pgsql): creation/update date + serial ids:
/!\ this patch updates pgqsl schema /!\
Had to set 2 features in the same patch, to avoid updating 2 times the schema.
1) creation/last modification date:
column keeping the date of creation of items is renamed from "date" to "created"
the date of last modification of items is saved in the new "updated" column
2) serial ids:
this experimental feature allows to have ids in series (i.e. 1, 2, 3, etc.) instead of UUID.
This is a convenience feature and there are some drawbacks:
- PostgreSQL sequences are used, so gaps can happen (see PostgreSQL documentation for more details)
- if somebody create an item with a future id in the series, the series will adapt, which can have undesired effect, and may lead to item fail if several items are created at the same time. For instance if next id in series is "8", and somebody hads already created item "8" and "256", the item will be created with biggest value in items +1 (i.e. 257). if 2 people want to create item in this situation, the second will fail with a conflict error.
author | Goffi <goffi@goffi.org> |
---|---|
date | Sat, 04 Nov 2017 21:31:32 +0100 |
parents | 9fbb31ce495b |
children | 618a92080812 |
comparison
equal
deleted
inserted
replaced
366:81e6d4a516c3 | 367:a772f7dac930 |
---|---|
592 (SUBSCRIBER_PENDING.resource, | 592 (SUBSCRIBER_PENDING.resource, |
593 SUBSCRIBER_PENDING.userhost())) | 593 SUBSCRIBER_PENDING.userhost())) |
594 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""", | 594 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""", |
595 (PUBLISHER.userhost(),)) | 595 (PUBLISHER.userhost(),)) |
596 cursor.execute("""INSERT INTO items | 596 cursor.execute("""INSERT INTO items |
597 (node_id, publisher, item, data, date) | 597 (node_id, publisher, item, data, created) |
598 SELECT node_id, %s, 'to-be-deleted', %s, | 598 SELECT node_id, %s, 'to-be-deleted', %s, |
599 now() - interval '1 day' | 599 now() - interval '1 day' |
600 FROM nodes | 600 FROM nodes |
601 WHERE node='pre-existing'""", | 601 WHERE node='pre-existing'""", |
602 (PUBLISHER.userhost(), | 602 (PUBLISHER.userhost(), |