Gecko [ fernandoquevedodop.com ]

Name	Size	Permission
__pycache__	[ DIR ]	drwxr-xr-x
__init__.py	536 B	-rw-r--r--
db10.py	1.17 KB	-rw-r--r--
db11.py	1.59 KB	-rw-r--r--
db12.py	1.36 KB	-rw-r--r--
db13.py	3.28 KB	-rw-r--r--
db14.py	1.72 KB	-rw-r--r--
db15.py	1.26 KB	-rw-r--r--
db16.py	1.59 KB	-rw-r--r--
db17.py	1.45 KB	-rw-r--r--
db18.py	3.16 KB	-rw-r--r--
db19.py	1.29 KB	-rw-r--r--
db20.py	1.48 KB	-rw-r--r--
db21.py	2.33 KB	-rw-r--r--
db22.py	851 B	-rw-r--r--
db23.py	2.67 KB	-rw-r--r--
db24.py	3.31 KB	-rw-r--r--
db25.py	1.8 KB	-rw-r--r--
db26.py	2.3 KB	-rw-r--r--
db27.py	994 B	-rw-r--r--
db28.py	3.45 KB	-rw-r--r--
db29.py	1.51 KB	-rw-r--r--
db3.py	962 B	-rw-r--r--
db30.py	1.75 KB	-rw-r--r--
db31.py	1.41 KB	-rw-r--r--
db32.py	2.92 KB	-rw-r--r--
db33.py	1.81 KB	-rw-r--r--
db34.py	1.22 KB	-rw-r--r--
db35.py	1.05 KB	-rw-r--r--
db36.py	1.01 KB	-rw-r--r--
db37.py	1.66 KB	-rw-r--r--
db38.py	1.78 KB	-rw-r--r--
db39.py	1.16 KB	-rw-r--r--
db4.py	828 B	-rw-r--r--
db40.py	1.89 KB	-rw-r--r--
db41.py	1.2 KB	-rw-r--r--
db42.py	714 B	-rw-r--r--
db43.py	2.62 KB	-rw-r--r--
db44.py	2.23 KB	-rw-r--r--
db45.py	1.46 KB	-rw-r--r--
db5.py	1.02 KB	-rw-r--r--
db6.py	724 B	-rw-r--r--
db7.py	1.13 KB	-rw-r--r--
db8.py	1.22 KB	-rw-r--r--
db9.py	1.21 KB	-rw-r--r--

Code Editor : db24.py

# -*- coding: utf-8 -*-
#
# Copyright (C) 2009-2021 Edgewall Software
# All rights reserved.
#
# This software is licensed as described in the file COPYING, which
# you should have received as part of this distribution. The terms
# are also available at https://trac.edgewall.org/wiki/TracLicense.
#
# This software consists of voluntary contributions made by many
# individuals. For the exact contribution history, see the revision
# history and logs, available at https://trac.edgewall.org/.

from trac.db import Table, Column, Index, DatabaseManager

def do_upgrade(env, ver, cursor):
    # Change repository key from reponame to a surrogate id
    cursor.execute("SELECT id FROM repository "
                   "UNION SELECT repos AS id FROM revision "
                   "UNION SELECT repos AS id FROM node_change "
                   "ORDER BY id")
    id_name_list = [(i + 1, name) for i, (name,) in enumerate(cursor)]

cursor.execute("CREATE TEMPORARY TABLE repo_old "
                   "AS SELECT * FROM repository")
    cursor.execute("DROP TABLE repository")
    cursor.execute("CREATE TEMPORARY TABLE rev_old "
                   "AS SELECT * FROM revision")
    cursor.execute("DROP TABLE revision")
    cursor.execute("CREATE TEMPORARY TABLE nc_old "
                   "AS SELECT * FROM node_change")
    cursor.execute("DROP TABLE node_change")

tables = [Table('repository', key=('id', 'name'))[
                  Column('id', type='int'),
                  Column('name'),
                  Column('value')],
              Table('revision', key=('repos', 'rev'))[
                  Column('repos', type='int'),
                  Column('rev', key_size=20),
                  Column('time', type='int'),
                  Column('author'),
                  Column('message'),
                  Index(['repos', 'time'])],
              Table('node_change', key=('repos', 'rev', 'path', 'change_type'))[
                  Column('repos', type='int'),
                  Column('rev', key_size=20),
                  Column('path', key_size=255),
                  Column('node_type', size=1),
                  Column('change_type', size=1, key_size=2),
                  Column('base_path'),
                  Column('base_rev'),
                  Index(['repos', 'rev'])]]

db_connector, _ = DatabaseManager(env).get_connector()
    for table in tables:
        for stmt in db_connector.to_sql(table):
            cursor.execute(stmt)

cursor.executemany("INSERT INTO repository (id,name,value) "
                       "VALUES (%s,'name',%s)", id_name_list)
    cursor.executemany("INSERT INTO repository (id,name,value) "
                       "SELECT %s,name,value FROM repo_old WHERE id=%s",
                       id_name_list)
    cursor.execute("DROP TABLE repo_old")
    cursor.executemany("INSERT INTO revision (repos,rev,time,author,message) "
                       "SELECT %s,rev,time,author,message FROM rev_old "
                       "WHERE repos=%s", id_name_list)
    cursor.execute("DROP TABLE rev_old")
    cursor.executemany("INSERT INTO node_change (repos,rev,path,node_type,"
                       "  change_type,base_path,base_rev) "
                       "SELECT %s,rev,path,node_type,change_type,base_path,"
                       "  base_rev FROM nc_old WHERE repos=%s", id_name_list)
    cursor.execute("DROP TABLE nc_old")

${this.title}

Code Editor : db24.py