← Back to branch summary

~launchpad-pqm/launchpad/devel

« back to all changes in this revision

Viewing changes to database/replication/generate_migration.py

  • Committer: Jeroen Vermeulen
  • Date: 2011-10-16 08:16:47 UTC
  • mto: This revision was merged to the branch mainline in revision 14165.
  • Revision ID: jeroen.vermeulen@canonical.com-20111016081647-nb3ab4mv9wwr68z2
Lint.

Show diffs side-by-side

added added

removed removed

Lines of Context:
database/replication/generate_migration.py
10
10
__metaclass__ = type
11
11
__all__ = []
12
12
 
13
 
import _pythonpath
14
 
 
15
13
from optparse import OptionParser
16
14
import os.path
17
15
from textwrap import dedent
18
16
 
19
 
from canonical.config import config
20
 
from canonical.database.sqlbase import connect
21
 
from canonical.launchpad import scripts
 
17
import _pythonpath
22
18
import replication.helpers
23
19
from replication.helpers import (
24
20
    LPMAIN_SET_ID,
28
24
    get_master_node,
29
25
    )
30
26
 
 
27
from canonical.database.sqlbase import connect
 
28
from canonical.launchpad import scripts
 
29
 
31
30
 
32
31
con = None
33
32
options = None
62
61
            origin = result[0]
63
62
            print >> outf, "define %s_origin %d;" % (set_name, origin)
64
63
        else:
65
 
            del sets[set_id] # For testing. Production will have 3 sets.
 
64
            del sets[set_id]  # For testing. Production will have 3 sets.
66
65
    outf.close()
67
66
 
68
67
 
118
117
            node.node_id, first_node.node_id)
119
118
 
120
119
    # Create paths so they can communicate.
121
 
    message(outf, "Storing %d paths" % pow(len(nodes),2))
 
120
    message(outf, "Storing %d paths" % pow(len(nodes), 2))
122
121
    for client_node in nodes:
123
122
        for server_node in nodes:
124
123
            print >> outf, (
158
157
    message(outf, "Adding %d tables to %s" % (len(results), set_name))
159
158
    for tab_id, tab_nspname, tab_relname, tab_comment in results:
160
159
        if not tab_comment:
161
 
            tab_comment=''
 
160
            tab_comment = ''
162
161
        print >> outf, dedent("""\
163
162
                set add table (
164
163
                    set id=@%s, origin=@%s_origin, id=%d,
175
174
    message(outf, "Adding %d sequences to %s" % (len(results), set_name))
176
175
    for seq_id, seq_nspname, seq_relname, seq_comment in results:
177
176
        if not seq_comment:
178
 
            seq_comment=''
 
177
            seq_comment = ''
179
178
        print >> outf, dedent("""\
180
179
                set add sequence (
181
180
                    set id=@%s, origin=@%s_origin, id=%d,
187
186
 
188
187
 
189
188
def generate_subscribe_set(set_id, set_name, outf):
190
 
    origin_node = get_master_node(con, set_id)
191
189
    cur = con.cursor()
192
190
    cur.execute("""
193
191
        SELECT sub_receiver FROM _sl.sl_subscribe