Changeset - 1f47adeb67c2
Parent rev.
Child rev.
[Not reviewed]
beta
0 9 0
Marcin Kuzminski - 14 years ago 2011-06-04 20:34:30
marcin@python-works.com
Bumped sqlalchemy version to 0.7, replaced timerproxy with new event system for sqlalchemy.
TimerProxy is now longer valid profilling method for sqlalchemy
9 files changed with 79 insertions and 42 deletions:
development.ini
5
5
production.ini
1
1
rhodecode/config/deployment.ini_tmpl
1
1
rhodecode/config/environment.py
1
6
rhodecode/lib/__init__.py
48
6
rhodecode/lib/colored_formatter.py
2
2
rhodecode/lib/timerproxy.py
1
1
rhodecode/model/db.py
18
18
setup.py
2
2
0 comments (0 inline, 0 general)
development.ini
➞
Show inline comments
 
@@ -139,15 +139,15 @@ logview.sqlalchemy = #faa
 
logview.pylons.templating = #bfb
 
logview.pylons.util = #eee
 

			




	
	
	
		
 
#########################################################

			




	
	
	
		
 
### DB CONFIGS - EACH DB WILL HAVE IT'S OWN CONFIG    ###

			




	
	
	
		
 
#########################################################

			




	
	
	
		
 
sqlalchemy.db1.url = sqlite:///%(here)s/rhodecode.db

			




	
	
	
		
 
#sqlalchemy.db1.url = postgresql://postgres:qwe@localhost/rhodecode

			




	
	
	
		
 
sqlalchemy.db1.echo = True

			




	
	
	
		
 
#sqlalchemy.db1.url = sqlite:///%(here)s/rhodecode.db

			




	
	
	
		
 
sqlalchemy.db1.url = postgresql://postgres:qwe@localhost/rhodecode

			




	
	
	
		
 
sqlalchemy.db1.echo = false

			




	
	
	
		
 
sqlalchemy.db1.pool_recycle = 3600

			




	
	
	
		
 
sqlalchemy.convert_unicode = true

			




	
	
	
		
 

			




	
	
	
		
 
################################

			




	
	
	
		
 
### LOGGING CONFIGURATION   ####

			




	
	
	
		
 
################################

			




	
	
		
 
@@ -202,19 +202,19 @@ propagate = 0

			




	
	
	
		
 
## HANDLERS ##

			




	
	
	
		
 
##############

			




	
	
	
		
 

			




	
	
	
		
 
[handler_console]

			




	
	
	
		
 
class = StreamHandler

			




	
	
	
		
 
args = (sys.stderr,)

			




	
	
	
		
 
level = NOTSET

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
formatter = color_formatter

			




	
	
	
		
 

			




	
	
	
		
 
[handler_console_sql]

			




	
	
	
		
 
class = StreamHandler

			




	
	
	
		
 
args = (sys.stderr,)

			




	
	
	
		
 
level = NOTSET

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
formatter = color_formatter_sql

			




	
	
	
		
 

			




	
	
	
		
 
################

			




	
	
	
		
 
## FORMATTERS ##

			




	
	
	
		
 
################

			




	
	
	
		
 

			




        

    


    
    

    

        

                

                    production.ini
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -141,13 +141,13 @@ logview.pylons.util = #eee

			




	
	
	
		
 

			




	
	
	
		
 
#########################################################

			




	
	
	
		
 
### DB CONFIGS - EACH DB WILL HAVE IT'S OWN CONFIG    ###

			




	
	
	
		
 
#########################################################

			




	
	
	
		
 
#sqlalchemy.db1.url = sqlite:///%(here)s/rhodecode.db

			




	
	
	
		
 
sqlalchemy.db1.url = postgresql://postgres:qwe@localhost/rhodecode

			




	
	
	
		
 
sqlalchemy.db1.echo = True

			




	
	
	
		
 
sqlalchemy.db1.echo = false

			




	
	
	
		
 
sqlalchemy.db1.pool_recycle = 3600

			




	
	
	
		
 
sqlalchemy.convert_unicode = true

			




	
	
	
		
 

			




	
	
	
		
 
################################

			




	
	
	
		
 
### LOGGING CONFIGURATION   ####

			




	
	
	
		
 
################################

			




        

    


    
    

    

        

                

                    rhodecode/config/deployment.ini_tmpl
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -140,13 +140,13 @@ logview.pylons.templating = #bfb

			




	
	
	
		
 
logview.pylons.util = #eee

			




	
	
	
		
 

			




	
	
	
		
 
#########################################################

			




	
	
	
		
 
### DB CONFIGS - EACH DB WILL HAVE IT'S OWN CONFIG    ###

			




	
	
	
		
 
#########################################################

			




	
	
	
		
 
sqlalchemy.db1.url = sqlite:///%(here)s/rhodecode.db

			




	
	
	
		
 
sqlalchemy.db1.echo = True

			




	
	
	
		
 
sqlalchemy.db1.echo = false

			




	
	
	
		
 
sqlalchemy.db1.pool_recycle = 3600

			




	
	
	
		
 
sqlalchemy.convert_unicode = true

			




	
	
	
		
 

			




	
	
	
		
 
################################

			




	
	
	
		
 
### LOGGING CONFIGURATION   ####

			




	
	
	
		
 
################################

			




        

    


    
    

    

        

                

                    rhodecode/config/environment.py
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -62,18 +62,13 @@ def load_environment(global_conf, app_co

			




	
	
	
		
 
        from rhodecode.tests import  TESTS_TMP_PATH

			




	
	
	
		
 
        create_test_env(TESTS_TMP_PATH, config)

			




	
	
	
		
 
        create_test_index(TESTS_TMP_PATH, True)

			




	
	
	
		
 

			




	
	
	
		
 
    #MULTIPLE DB configs

			




	
	
	
		
 
    # Setup the SQLAlchemy database engine

			




	
	
	
		
 
    if config['debug'] and not test:

			




	
	
	
		
 
        #use query time debugging.

			




	
	
	
		
 
        sa_engine_db1 = engine_from_config(config, 'sqlalchemy.db1.',

			




	
	
	
		
 
                                           proxy=TimerProxy())

			




	
	
	
		
 
    else:

			




	
	
	
		
 
        sa_engine_db1 = engine_from_config(config, 'sqlalchemy.db1.')

			




	
	
	
		
 
    sa_engine_db1 = engine_from_config(config, 'sqlalchemy.db1.')

			




	
	
	
		
 

			




	
	
	
		
 
    init_model(sa_engine_db1)

			




	
	
	
		
 

			




	
	
	
		
 
    repos_path = make_ui('db').configitems('paths')[0][1]

			




	
	
	
		
 
    repo2db_mapper(ScmModel().repo_scan(repos_path))

			




	
	
	
		
 
    set_available_permissions(config)

			




        

    


    
    

    

        

                

                    rhodecode/lib/__init__.py
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -158,24 +158,66 @@ def safe_unicode(_str, from_encoding='ut

			




	
	
	
		
 
    return u_str

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
def engine_from_config(configuration, prefix='sqlalchemy.', **kwargs):

			




	
	
	
		
 
    """

			




	
	
	
		
 
    Custom engine_from_config functions that makes sure we use NullPool for

			




	
	
	
		
 
    file based sqlite databases. This prevents errors on sqlite.

			




	
	
	
		
 
    file based sqlite databases. This prevents errors on sqlite. This only 

			




	
	
	
		
 
    applies to sqlalchemy versions < 0.7.0

			




	
	
	
		
 

			




	
	
	
		
 
    """

			




	
	
	
		
 
    import sqlalchemy

			




	
	
	
		
 
    from sqlalchemy import engine_from_config as efc

			




	
	
	
		
 
    from sqlalchemy.pool import NullPool

			




	
	
	
		
 
    import logging

			




	
	
	
		
 

			




	
	
	
		
 
    if int(sqlalchemy.__version__.split('.')[1]) < 7:

			




	
	
	
		
 

			




	
	
	
		
 
        # This solution should work for sqlalchemy < 0.7.0, and should use

			




	
	
	
		
 
        # proxy=TimerProxy() for execution time profiling

			




	
	
	
		
 

			




	
	
	
		
 
        from sqlalchemy.pool import NullPool

			




	
	
	
		
 
        url = configuration[prefix + 'url']

			




	
	
	
		
 

			




	
	
	
		
 
    url = configuration[prefix + 'url']

			




	
	
	
		
 
        if url.startswith('sqlite'):

			




	
	
	
		
 
            kwargs.update({'poolclass': NullPool})

			




	
	
	
		
 
        return efc(configuration, prefix, **kwargs)

			




	
	
	
		
 
    else:

			




	
	
	
		
 
        import time

			




	
	
	
		
 
        from sqlalchemy import event

			




	
	
	
		
 
        from sqlalchemy.engine import Engine

			




	
	
	
		
 

			




	
	
	
		
 
        log = logging.getLogger('timerproxy')

			




	
	
	
		
 
        BLACK, RED, GREEN, YELLOW, BLUE, MAGENTA, CYAN, WHITE = xrange(30, 38)

			




	
	
	
		
 
        engine = efc(configuration, prefix, **kwargs)

			




	
	
	
		
 

			




	
	
	
		
 
    if url.startswith('sqlite'):

			




	
	
	
		
 
        kwargs.update({'poolclass': NullPool})

			




	
	
	
		
 
        def color_sql(sql):

			




	
	
	
		
 
            COLOR_SEQ = "\033[1;%dm"

			




	
	
	
		
 
            COLOR_SQL = YELLOW

			




	
	
	
		
 
            normal = '\x1b[0m'

			




	
	
	
		
 
            return ''.join([COLOR_SEQ % COLOR_SQL, sql, normal])

			




	
	
	
		
 

			




	
	
	
		
 
        if configuration['debug']:

			




	
	
	
		
 
            #attach events only for debug configuration

			




	
	
	
		
 

			




	
	
	
		
 
    return efc(configuration, prefix, **kwargs)

			




	
	
	
		
 
            def before_cursor_execute(conn, cursor, statement,

			




	
	
	
		
 
                                    parameters, context, executemany):

			




	
	
	
		
 
                context._query_start_time = time.time()

			




	
	
	
		
 
                log.info(color_sql(">>>>> STARTING QUERY >>>>>"))

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
            def after_cursor_execute(conn, cursor, statement,

			




	
	
	
		
 
                                    parameters, context, executemany):

			




	
	
	
		
 
                total = time.time() - context._query_start_time

			




	
	
	
		
 
                log.info(color_sql("<<<<< TOTAL TIME: %f <<<<<" % total))

			




	
	
	
		
 

			




	
	
	
		
 
            event.listen(engine, "before_cursor_execute",

			




	
	
	
		
 
                         before_cursor_execute)

			




	
	
	
		
 
            event.listen(engine, "after_cursor_execute",

			




	
	
	
		
 
                         after_cursor_execute)

			




	
	
	
		
 

			




	
	
	
		
 
    return engine

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
def age(curdate):

			




	
	
	
		
 
    """

			




	
	
	
		
 
    turns a datetime into an age string.

			




	
	
	
		
 
    

			




        

    


    
    

    

        

                

                    rhodecode/lib/colored_formatter.py
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -59,13 +59,13 @@ class ColorFormatter(logging.Formatter):

			




	
	
	
		
 

			




	
	
	
		
 
        levelname = record.levelname

			




	
	
	
		
 
        start = COLOR_SEQ % (COLORS[levelname])

			




	
	
	
		
 
        def_record = logging.Formatter.format(self, record)

			




	
	
	
		
 
        end = RESET_SEQ

			




	
	
	
		
 

			




	
	
	
		
 
        colored_record = start + def_record + end

			




	
	
	
		
 
        colored_record = ''.join([start, def_record, end])

			




	
	
	
		
 
        return colored_record

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
class ColorFormatterSql(logging.Formatter):

			




	
	
	
		
 

			




	
	
	
		
 
    def __init__(self, *args, **kwargs):

			




	
	
		
 
@@ -78,8 +78,8 @@ class ColorFormatterSql(logging.Formatte

			




	
	
	
		
 
        """

			




	
	
	
		
 

			




	
	
	
		
 
        start = COLOR_SEQ % (COLORS['SQL'])

			




	
	
	
		
 
        def_record = format_sql(logging.Formatter.format(self, record))

			




	
	
	
		
 
        end = RESET_SEQ

			




	
	
	
		
 

			




	
	
	
		
 
        colored_record = start + def_record + end

			




	
	
	
		
 
        colored_record = ''.join([start, def_record, end])

			




	
	
	
		
 
        return colored_record

			




        

    


    
    

    

        

                

                    rhodecode/lib/timerproxy.py
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -7,13 +7,13 @@ BLACK, RED, GREEN, YELLOW, BLUE, MAGENTA

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
def color_sql(sql):

			




	
	
	
		
 
    COLOR_SEQ = "\033[1;%dm"

			




	
	
	
		
 
    COLOR_SQL = YELLOW

			




	
	
	
		
 
    normal = '\x1b[0m'

			




	
	
	
		
 
    return COLOR_SEQ % COLOR_SQL + sql + normal

			




	
	
	
		
 
    return ''.join([COLOR_SEQ % COLOR_SQL, sql, normal])

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
class TimerProxy(ConnectionProxy):

			




	
	
	
		
 

			




	
	
	
		
 
    def __init__(self):

			




	
	
	
		
 
        super(TimerProxy, self).__init__()

			




        

    


    
    

    

        

                

                    rhodecode/model/db.py
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -47,13 +47,13 @@ class RepositoryMapper(MapperExtension):

			




	
	
	
		
 
    def after_update(self, mapper, connection, instance):

			




	
	
	
		
 
        pass

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
class RhodeCodeSettings(Base):

			




	
	
	
		
 
    __tablename__ = 'rhodecode_settings'

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('app_settings_name'), {'useexisting':True})

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('app_settings_name'), {'extend_existing':True})

			




	
	
	
		
 
    app_settings_id = Column("app_settings_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    app_settings_name = Column("app_settings_name", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    app_settings_value = Column("app_settings_value", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
	
		
 

			




	
	
	
		
 
    def __init__(self, k='', v=''):

			




	
	
	
		
 
        self.app_settings_name = k

			




	
	
		
 
@@ -96,13 +96,13 @@ class RhodeCodeSettings(Base):

			




	
	
	
		
 
            fd.update({row.app_settings_name:row.app_settings_value})

			




	
	
	
		
 
        return fd

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
class RhodeCodeUi(Base):

			




	
	
	
		
 
    __tablename__ = 'rhodecode_ui'

			




	
	
	
		
 
    __table_args__ = {'useexisting':True}

			




	
	
	
		
 
    __table_args__ = {'extend_existing':True}

			




	
	
	
		
 
    ui_id = Column("ui_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    ui_section = Column("ui_section", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    ui_key = Column("ui_key", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    ui_value = Column("ui_value", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    ui_active = Column("ui_active", Boolean(), nullable=True, unique=None, default=True)

			




	
	
	
		
 

			




	
	
		
 
@@ -111,13 +111,13 @@ class RhodeCodeUi(Base):

			




	
	
	
		
 
    def get_by_key(cls, key):

			




	
	
	
		
 
        return Session.query(cls).filter(cls.ui_key == key)

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
class User(Base):

			




	
	
	
		
 
    __tablename__ = 'users'

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('username'), UniqueConstraint('email'), {'useexisting':True})

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('username'), UniqueConstraint('email'), {'extend_existing':True})

			




	
	
	
		
 
    user_id = Column("user_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    username = Column("username", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    password = Column("password", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    active = Column("active", Boolean(), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    admin = Column("admin", Boolean(), nullable=True, unique=None, default=False)

			




	
	
	
		
 
    name = Column("name", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
		
 
@@ -170,16 +170,16 @@ class User(Base):

			




	
	
	
		
 
        except (DatabaseError,):

			




	
	
	
		
 
            session.rollback()

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
class UserLog(Base):

			




	
	
	
		
 
    __tablename__ = 'user_logs'

			




	
	
	
		
 
    __table_args__ = {'useexisting':True}

			




	
	
	
		
 
    __table_args__ = {'extend_existing':True}

			




	
	
	
		
 
    user_log_id = Column("user_log_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    user_id = Column("user_id", Integer(), ForeignKey('users.user_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 
    repository_id = Column("repository_id", Integer(length=None, convert_unicode=False, assert_unicode=None), ForeignKey('repositories.repo_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 
    repository_id = Column("repository_id", Integer(), ForeignKey('repositories.repo_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 
    repository_name = Column("repository_name", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    user_ip = Column("user_ip", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    action = Column("action", UnicodeText(length=1200000, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    action_date = Column("action_date", DateTime(timezone=False), nullable=True, unique=None, default=None)

			




	
	
	
		
 

			




	
	
	
		
 
    @property

			




	
	
		
 
@@ -189,13 +189,13 @@ class UserLog(Base):

			




	
	
	
		
 
    user = relationship('User')

			




	
	
	
		
 
    repository = relationship('Repository')

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
class UsersGroup(Base):

			




	
	
	
		
 
    __tablename__ = 'users_groups'

			




	
	
	
		
 
    __table_args__ = {'useexisting':True}

			




	
	
	
		
 
    __table_args__ = {'extend_existing':True}

			




	
	
	
		
 

			




	
	
	
		
 
    users_group_id = Column("users_group_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    users_group_name = Column("users_group_name", String(length=255, convert_unicode=False, assert_unicode=None), nullable=False, unique=True, default=None)

			




	
	
	
		
 
    users_group_active = Column("users_group_active", Boolean(), nullable=True, unique=None, default=None)

			




	
	
	
		
 

			




	
	
	
		
 
    members = relationship('UsersGroupMember', cascade="all, delete, delete-orphan", lazy="joined")

			




	
	
		
 
@@ -213,13 +213,13 @@ class UsersGroup(Base):

			




	
	
	
		
 
            gr = gr.options(FromCache("sql_cache_short",

			




	
	
	
		
 
                                          "get_user_%s" % group_name))

			




	
	
	
		
 
        return gr.scalar()

			




	
	
	
		
 

			




	
	
	
		
 
class UsersGroupMember(Base):

			




	
	
	
		
 
    __tablename__ = 'users_groups_members'

			




	
	
	
		
 
    __table_args__ = {'useexisting':True}

			




	
	
	
		
 
    __table_args__ = {'extend_existing':True}

			




	
	
	
		
 

			




	
	
	
		
 
    users_group_member_id = Column("users_group_member_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    users_group_id = Column("users_group_id", Integer(), ForeignKey('users_groups.users_group_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 
    user_id = Column("user_id", Integer(), ForeignKey('users.user_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 

			




	
	
	
		
 
    user = relationship('User', lazy='joined')

			




	
	
		
 
@@ -228,13 +228,13 @@ class UsersGroupMember(Base):

			




	
	
	
		
 
    def __init__(self, gr_id='', u_id=''):

			




	
	
	
		
 
        self.users_group_id = gr_id

			




	
	
	
		
 
        self.user_id = u_id

			




	
	
	
		
 

			




	
	
	
		
 
class Repository(Base):

			




	
	
	
		
 
    __tablename__ = 'repositories'

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('repo_name'), {'useexisting':True},)

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('repo_name'), {'extend_existing':True},)

			




	
	
	
		
 
    __mapper_args__ = {'extension':RepositoryMapper()}

			




	
	
	
		
 

			




	
	
	
		
 
    repo_id = Column("repo_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    repo_name = Column("repo_name", String(length=255, convert_unicode=False, assert_unicode=None), nullable=False, unique=True, default=None)

			




	
	
	
		
 
    clone_uri = Column("clone_uri", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=False, default=None)

			




	
	
	
		
 
    repo_type = Column("repo_type", String(length=255, convert_unicode=False, assert_unicode=None), nullable=False, unique=False, default='hg')

			




	
	
		
 
@@ -299,13 +299,13 @@ class Repository(Base):

			




	
	
	
		
 
        return self.groups_with_parents, self.just_name

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
class Group(Base):

			




	
	
	
		
 
    __tablename__ = 'groups'

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('group_name', 'group_parent_id'),

			




	
	
	
		
 
                      CheckConstraint('group_id != group_parent_id'), {'useexisting':True},)

			




	
	
	
		
 
                      CheckConstraint('group_id != group_parent_id'), {'extend_existing':True},)

			




	
	
	
		
 
    __mapper_args__ = {'order_by':'group_name'}

			




	
	
	
		
 

			




	
	
	
		
 
    group_id = Column("group_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    group_name = Column("group_name", String(length=255, convert_unicode=False, assert_unicode=None), nullable=False, unique=True, default=None)

			




	
	
	
		
 
    group_parent_id = Column("group_parent_id", Integer(), ForeignKey('groups.group_id'), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    group_description = Column("group_description", String(length=10000, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
		
 
@@ -358,13 +358,13 @@ class Group(Base):

			




	
	
	
		
 
    @property

			




	
	
	
		
 
    def repositories(self):

			




	
	
	
		
 
        return Session.query(Repository).filter(Repository.group == self)

			




	
	
	
		
 

			




	
	
	
		
 
class Permission(Base):

			




	
	
	
		
 
    __tablename__ = 'permissions'

			




	
	
	
		
 
    __table_args__ = {'useexisting':True}

			




	
	
	
		
 
    __table_args__ = {'extend_existing':True}

			




	
	
	
		
 
    permission_id = Column("permission_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    permission_name = Column("permission_name", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    permission_longname = Column("permission_longname", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
	
		
 

			




	
	
	
		
 
    def __repr__(self):

			




	
	
	
		
 
        return "<%s('%s:%s')>" % (self.__class__.__name__,

			




	
	
		
 
@@ -373,25 +373,25 @@ class Permission(Base):

			




	
	
	
		
 
    @classmethod

			




	
	
	
		
 
    def get_by_key(cls, key):

			




	
	
	
		
 
        return Session.query(cls).filter(cls.permission_name == key).scalar()

			




	
	
	
		
 

			




	
	
	
		
 
class RepoToPerm(Base):

			




	
	
	
		
 
    __tablename__ = 'repo_to_perm'

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('user_id', 'repository_id'), {'useexisting':True})

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('user_id', 'repository_id'), {'extend_existing':True})

			




	
	
	
		
 
    repo_to_perm_id = Column("repo_to_perm_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    user_id = Column("user_id", Integer(), ForeignKey('users.user_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 
    permission_id = Column("permission_id", Integer(), ForeignKey('permissions.permission_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 
    repository_id = Column("repository_id", Integer(), ForeignKey('repositories.repo_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 

			




	
	
	
		
 
    user = relationship('User')

			




	
	
	
		
 
    permission = relationship('Permission')

			




	
	
	
		
 
    repository = relationship('Repository')

			




	
	
	
		
 

			




	
	
	
		
 
class UserToPerm(Base):

			




	
	
	
		
 
    __tablename__ = 'user_to_perm'

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('user_id', 'permission_id'), {'useexisting':True})

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('user_id', 'permission_id'), {'extend_existing':True})

			




	
	
	
		
 
    user_to_perm_id = Column("user_to_perm_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    user_id = Column("user_id", Integer(), ForeignKey('users.user_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 
    permission_id = Column("permission_id", Integer(), ForeignKey('permissions.permission_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 

			




	
	
	
		
 
    user = relationship('User')

			




	
	
	
		
 
    permission = relationship('Permission')

			




	
	
		
 
@@ -430,13 +430,13 @@ class UserToPerm(Base):

			




	
	
	
		
 
            Session.commit()

			




	
	
	
		
 
        except:

			




	
	
	
		
 
            Session.rollback()

			




	
	
	
		
 

			




	
	
	
		
 
class UsersGroupRepoToPerm(Base):

			




	
	
	
		
 
    __tablename__ = 'users_group_repo_to_perm'

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('users_group_id', 'permission_id'), {'useexisting':True})

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('users_group_id', 'permission_id'), {'extend_existing':True})

			




	
	
	
		
 
    users_group_to_perm_id = Column("users_group_to_perm_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    users_group_id = Column("users_group_id", Integer(), ForeignKey('users_groups.users_group_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 
    permission_id = Column("permission_id", Integer(), ForeignKey('permissions.permission_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 
    repository_id = Column("repository_id", Integer(), ForeignKey('repositories.repo_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 

			




	
	
	
		
 
    users_group = relationship('UsersGroup')

			




	
	
		
 
@@ -491,26 +491,26 @@ class UsersGroupToPerm(Base):

			




	
	
	
		
 
        except:

			




	
	
	
		
 
            Session.rollback()

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
class GroupToPerm(Base):

			




	
	
	
		
 
    __tablename__ = 'group_to_perm'

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('group_id', 'permission_id'), {'useexisting':True})

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('group_id', 'permission_id'), {'extend_existing':True})

			




	
	
	
		
 

			




	
	
	
		
 
    group_to_perm_id = Column("group_to_perm_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    user_id = Column("user_id", Integer(), ForeignKey('users.user_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 
    permission_id = Column("permission_id", Integer(), ForeignKey('permissions.permission_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 
    group_id = Column("group_id", Integer(), ForeignKey('groups.group_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 

			




	
	
	
		
 
    user = relationship('User')

			




	
	
	
		
 
    permission = relationship('Permission')

			




	
	
	
		
 
    group = relationship('Group')

			




	
	
	
		
 

			




	
	
	
		
 
class Statistics(Base):

			




	
	
	
		
 
    __tablename__ = 'statistics'

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('repository_id'), {'useexisting':True})

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('repository_id'), {'extend_existing':True})

			




	
	
	
		
 
    stat_id = Column("stat_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    repository_id = Column("repository_id", Integer(), ForeignKey('repositories.repo_id'), nullable=False, unique=True, default=None)

			




	
	
	
		
 
    stat_on_revision = Column("stat_on_revision", Integer(), nullable=False)

			




	
	
	
		
 
    commit_activity = Column("commit_activity", LargeBinary(1000000), nullable=False)#JSON data

			




	
	
	
		
 
    commit_activity_combined = Column("commit_activity_combined", LargeBinary(), nullable=False)#JSON data

			




	
	
	
		
 
    languages = Column("languages", LargeBinary(1000000), nullable=False)#JSON data

			




	
	
		
 
@@ -518,13 +518,13 @@ class Statistics(Base):

			




	
	
	
		
 
    repository = relationship('Repository', single_parent=True)

			




	
	
	
		
 

			




	
	
	
		
 
class UserFollowing(Base):

			




	
	
	
		
 
    __tablename__ = 'user_followings'

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('user_id', 'follows_repository_id'),

			




	
	
	
		
 
                      UniqueConstraint('user_id', 'follows_user_id')

			




	
	
	
		
 
                      , {'useexisting':True})

			




	
	
	
		
 
                      , {'extend_existing':True})

			




	
	
	
		
 

			




	
	
	
		
 
    user_following_id = Column("user_following_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    user_id = Column("user_id", Integer(), ForeignKey('users.user_id'), nullable=False, unique=None, default=None)

			




	
	
	
		
 
    follows_repo_id = Column("follows_repository_id", Integer(), ForeignKey('repositories.repo_id'), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    follows_user_id = Column("follows_user_id", Integer(), ForeignKey('users.user_id'), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    follows_from = Column('follows_from', DateTime(timezone=False), nullable=True, unique=None, default=datetime.datetime.now)

			




	
	
		
 
@@ -539,13 +539,13 @@ class UserFollowing(Base):

			




	
	
	
		
 
    @classmethod

			




	
	
	
		
 
    def get_repo_followers(cls, repo_id):

			




	
	
	
		
 
        return Session.query(cls).filter(cls.follows_repo_id == repo_id)

			




	
	
	
		
 

			




	
	
	
		
 
class CacheInvalidation(Base):

			




	
	
	
		
 
    __tablename__ = 'cache_invalidation'

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('cache_key'), {'useexisting':True})

			




	
	
	
		
 
    __table_args__ = (UniqueConstraint('cache_key'), {'extend_existing':True})

			




	
	
	
		
 
    cache_id = Column("cache_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

			




	
	
	
		
 
    cache_key = Column("cache_key", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    cache_args = Column("cache_args", String(length=255, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

			




	
	
	
		
 
    cache_active = Column("cache_active", Boolean(), nullable=True, unique=None, default=False)

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
		
 
@@ -557,10 +557,10 @@ class CacheInvalidation(Base):

			




	
	
	
		
 
    def __repr__(self):

			




	
	
	
		
 
        return "<%s('%s:%s')>" % (self.__class__.__name__,

			




	
	
	
		
 
                                  self.cache_id, self.cache_key)

			




	
	
	
		
 

			




	
	
	
		
 
class DbMigrateVersion(Base):

			




	
	
	
		
 
    __tablename__ = 'db_migrate_version'

			




	
	
	
		
 
    __table_args__ = {'useexisting':True}

			




	
	
	
		
 
    __table_args__ = {'extend_existing':True}

			




	
	
	
		
 
    repository_id = Column('repository_id', String(250), primary_key=True)

			




	
	
	
		
 
    repository_path = Column('repository_path', Text)

			




	
	
	
		
 
    version = Column('version', Integer)

			




        

    


    
    

    

        

                

                    setup.py
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -9,18 +9,18 @@ py_version = sys.version_info

			




	
	
	
		
 
if py_version < (2, 5):

			




	
	
	
		
 
    raise Exception('RhodeCode requires python 2.5 or later')

			




	
	
	
		
 

			




	
	
	
		
 
requirements = [

			




	
	
	
		
 
        "Pylons==1.0.0",

			




	
	
	
		
 
        "WebHelpers>=1.2",

			




	
	
	
		
 
        "SQLAlchemy>=0.6.6",

			




	
	
	
		
 
        "SQLAlchemy>=0.7.0",

			




	
	
	
		
 
        "Mako>=0.4.0",

			




	
	
	
		
 
        "vcs>=0.2.1",

			




	
	
	
		
 
        "pygments>=1.4",

			




	
	
	
		
 
        "mercurial>=1.8.1",

			




	
	
	
		
 
        "whoosh>=1.8.0",

			




	
	
	
		
 
        "whoosh>=1.8.4",

			




	
	
	
		
 
        "celery>=2.2.5",

			




	
	
	
		
 
        "babel",

			




	
	
	
		
 
        "python-dateutil>=1.5.0,<2.0.0",

			




	
	
	
		
 
        "dulwich>=0.7.1"

			




	
	
	
		
 
    ]

			




	
	
	
		
 

			




        

    



    


    



    



      

      





    
    0 comments (0 inline, 0 general)
    





    


  

  







  


    




    








    
        
    
    
        This site is powered by
            Kallithea 0.7.0,
        which is
        © 2010–2025 by various authors & licensed under GPLv3.