Mercurial > libervia-pubsub

comparison idavoll/test/test_storage.py @ 137:aca904a41a43

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Discover client_encoding parameter to pyPgSQL.
author Ralph Meijer <ralphm@ik.nu>
date Mon, 25 Apr 2005 12:58:59 +0000
parents fe8cb99363ff
children 635e433810ef
comparison
equal deleted inserted replaced
136:327de183f48d 137:aca904a41a43
358 cursor.execute("""INSERT INTO nodes (node) VALUES ('pre-existing')""") 358 cursor.execute("""INSERT INTO nodes (node) VALUES ('pre-existing')""")
359 cursor.execute("""INSERT INTO nodes (node) VALUES ('to-be-deleted')""") 359 cursor.execute("""INSERT INTO nodes (node) VALUES ('to-be-deleted')""")
360 cursor.execute("""INSERT INTO nodes (node) VALUES ('to-be-reconfigured')""") 360 cursor.execute("""INSERT INTO nodes (node) VALUES ('to-be-reconfigured')""")
361 cursor.execute("""INSERT INTO nodes (node) VALUES ('to-be-purged')""") 361 cursor.execute("""INSERT INTO nodes (node) VALUES ('to-be-purged')""")
362 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""", 362 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""",
363 OWNER.userhost().encode('utf-8')) 363 OWNER.userhost())
364 cursor.execute("""INSERT INTO affiliations 364 cursor.execute("""INSERT INTO affiliations
365 (node_id, entity_id, affiliation) 365 (node_id, entity_id, affiliation)
366 SELECT nodes.id, entities.id, 'owner' 366 SELECT nodes.id, entities.id, 'owner'
367 FROM nodes, entities 367 FROM nodes, entities
368 WHERE node='pre-existing' AND jid=%s""", 368 WHERE node='pre-existing' AND jid=%s""",
369 OWNER.userhost().encode('utf-8')) 369 OWNER.userhost())
370 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""", 370 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""",
371 SUBSCRIBER.userhost().encode('utf-8')) 371 SUBSCRIBER.userhost())
372 cursor.execute("""INSERT INTO subscriptions 372 cursor.execute("""INSERT INTO subscriptions
373 (node_id, entity_id, resource, subscription) 373 (node_id, entity_id, resource, subscription)
374 SELECT nodes.id, entities.id, %s, 'subscribed' 374 SELECT nodes.id, entities.id, %s, 'subscribed'
375 FROM nodes, entities 375 FROM nodes, entities
376 WHERE node='pre-existing' AND jid=%s""", 376 WHERE node='pre-existing' AND jid=%s""",
377 (SUBSCRIBER.resource.encode('utf-8'), 377 (SUBSCRIBER.resource,
378 SUBSCRIBER.userhost().encode('utf-8'))) 378 SUBSCRIBER.userhost()))
379 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""", 379 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""",
380 SUBSCRIBER_TO_BE_DELETED.userhost().encode('utf-8')) 380 SUBSCRIBER_TO_BE_DELETED.userhost())
381 cursor.execute("""INSERT INTO subscriptions 381 cursor.execute("""INSERT INTO subscriptions
382 (node_id, entity_id, resource, subscription) 382 (node_id, entity_id, resource, subscription)
383 SELECT nodes.id, entities.id, %s, 'subscribed' 383 SELECT nodes.id, entities.id, %s, 'subscribed'
384 FROM nodes, entities 384 FROM nodes, entities
385 WHERE node='pre-existing' AND jid=%s""", 385 WHERE node='pre-existing' AND jid=%s""",
386 (SUBSCRIBER_TO_BE_DELETED.resource.encode('utf-8'), 386 (SUBSCRIBER_TO_BE_DELETED.resource,
387 SUBSCRIBER_TO_BE_DELETED.userhost().encode('utf-8'))) 387 SUBSCRIBER_TO_BE_DELETED.userhost()))
388 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""", 388 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""",
389 SUBSCRIBER_PENDING.userhost().encode('utf-8')) 389 SUBSCRIBER_PENDING.userhost())
390 cursor.execute("""INSERT INTO subscriptions 390 cursor.execute("""INSERT INTO subscriptions
391 (node_id, entity_id, resource, subscription) 391 (node_id, entity_id, resource, subscription)
392 SELECT nodes.id, entities.id, %s, 'pending' 392 SELECT nodes.id, entities.id, %s, 'pending'
393 FROM nodes, entities 393 FROM nodes, entities
394 WHERE node='pre-existing' AND jid=%s""", 394 WHERE node='pre-existing' AND jid=%s""",
395 (SUBSCRIBER_PENDING.resource.encode('utf-8'), 395 (SUBSCRIBER_PENDING.resource,
396 SUBSCRIBER_PENDING.userhost().encode('utf-8'))) 396 SUBSCRIBER_PENDING.userhost()))
397 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""", 397 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""",
398 PUBLISHER.userhost().encode('utf-8')) 398 PUBLISHER.userhost())
399 cursor.execute("""INSERT INTO items 399 cursor.execute("""INSERT INTO items
400 (node_id, publisher, item, data, date) 400 (node_id, publisher, item, data, date)
401 SELECT nodes.id, %s, 'to-be-deleted', %s, 401 SELECT nodes.id, %s, 'to-be-deleted', %s,
402 now() - interval '1 day' 402 now() - interval '1 day'
403 FROM nodes 403 FROM nodes
404 WHERE node='pre-existing'""", 404 WHERE node='pre-existing'""",
405 (PUBLISHER.userhost().encode('utf-8'), 405 (PUBLISHER.userhost(),
406 ITEM_TO_BE_DELETED.toXml())) 406 ITEM_TO_BE_DELETED.toXml()))
407 cursor.execute("""INSERT INTO items 407 cursor.execute("""INSERT INTO items
408 (node_id, publisher, item, data, date) 408 (node_id, publisher, item, data, date)
409 SELECT nodes.id, %s, 'to-not-be-deleted', %s, 409 SELECT nodes.id, %s, 'to-not-be-deleted', %s,
410 now() - interval '1 day' 410 now() - interval '1 day'
411 FROM nodes 411 FROM nodes
412 WHERE node='pre-existing'""", 412 WHERE node='pre-existing'""",
413 (PUBLISHER.userhost().encode('utf-8'), 413 (PUBLISHER.userhost(),
414 ITEM_TO_NOT_BE_DELETED.toXml())) 414 ITEM_TO_NOT_BE_DELETED.toXml()))
415 cursor.execute("""INSERT INTO items (node_id, publisher, item, data) 415 cursor.execute("""INSERT INTO items (node_id, publisher, item, data)
416 SELECT nodes.id, %s, 'to-be-deleted', %s 416 SELECT nodes.id, %s, 'to-be-deleted', %s
417 FROM nodes 417 FROM nodes
418 WHERE node='to-be-purged'""", 418 WHERE node='to-be-purged'""",
419 (PUBLISHER.userhost().encode('utf-8'), 419 (PUBLISHER.userhost(),
420 ITEM_TO_BE_DELETED.toXml())) 420 ITEM_TO_BE_DELETED.toXml()))
421 cursor.execute("""INSERT INTO items (node_id, publisher, item, data) 421 cursor.execute("""INSERT INTO items (node_id, publisher, item, data)
422 SELECT nodes.id, %s, 'current', %s 422 SELECT nodes.id, %s, 'current', %s
423 FROM nodes 423 FROM nodes
424 WHERE node='pre-existing'""", 424 WHERE node='pre-existing'""",
425 (PUBLISHER.userhost().encode('utf-8'), 425 (PUBLISHER.userhost(),
426 ITEM.toXml())) 426 ITEM.toXml()))
427 427
428 def cleandb(self, cursor): 428 def cleandb(self, cursor):
429 cursor.execute("""DELETE FROM nodes WHERE node in 429 cursor.execute("""DELETE FROM nodes WHERE node in
430 ('non-existing', 'pre-existing', 'to-be-deleted', 430 ('non-existing', 'pre-existing', 'to-be-deleted',
431 'new 1', 'new 2', 'new 3', 'to-be-reconfigured', 431 'new 1', 'new 2', 'new 3', 'to-be-reconfigured',
432 'to-be-purged')""") 432 'to-be-purged')""")
433 cursor.execute("""DELETE FROM entities WHERE jid=%s""", 433 cursor.execute("""DELETE FROM entities WHERE jid=%s""",
434 OWNER.userhost().encode('utf-8')) 434 OWNER.userhost())
435 cursor.execute("""DELETE FROM entities WHERE jid=%s""", 435 cursor.execute("""DELETE FROM entities WHERE jid=%s""",
436 SUBSCRIBER.userhost().encode('utf-8')) 436 SUBSCRIBER.userhost())
437 cursor.execute("""DELETE FROM entities WHERE jid=%s""", 437 cursor.execute("""DELETE FROM entities WHERE jid=%s""",
438 SUBSCRIBER_TO_BE_DELETED.userhost().encode('utf-8')) 438 SUBSCRIBER_TO_BE_DELETED.userhost())
439 cursor.execute("""DELETE FROM entities WHERE jid=%s""", 439 cursor.execute("""DELETE FROM entities WHERE jid=%s""",
440 SUBSCRIBER_PENDING.userhost().encode('utf-8')) 440 SUBSCRIBER_PENDING.userhost())
441 cursor.execute("""DELETE FROM entities WHERE jid=%s""", 441 cursor.execute("""DELETE FROM entities WHERE jid=%s""",
442 PUBLISHER.userhost().encode('utf-8')) 442 PUBLISHER.userhost())