Mercurial > libervia-pubsub
comparison idavoll/test/test_storage.py @ 137:aca904a41a43
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()) |