Ticket #15131: django_pg_service.patch

File django_pg_service.patch, 2.8 KB (added by valczir.darkvein@…, 14 years ago)

Example patch to django/db/backends/postgresql_psycopg2/base.py to get pg_service working

  • base.py

    a b  
    116116        if self.connection is None:
    117117            new_connection = True
    118118            set_tz = settings_dict.get('TIME_ZONE')
    119             if settings_dict['NAME'] == '':
    120                 from django.core.exceptions import ImproperlyConfigured
    121                 raise ImproperlyConfigured("You need to specify NAME in your Django settings file.")
    122             conn_params = {
    123                 'database': settings_dict['NAME'],
    124             }
    125             conn_params.update(settings_dict['OPTIONS'])
    126             if 'autocommit' in conn_params:
    127                 del conn_params['autocommit']
    128             if settings_dict['USER']:
    129                 conn_params['user'] = settings_dict['USER']
    130             if settings_dict['PASSWORD']:
    131                 conn_params['password'] = settings_dict['PASSWORD']
    132             if settings_dict['HOST']:
    133                 conn_params['host'] = settings_dict['HOST']
    134             if settings_dict['PORT']:
    135                 conn_params['port'] = settings_dict['PORT']
    136             self.connection = Database.connect(**conn_params)
     119
     120            if 'SERVICE' in settings_dict and settings_dict['SERVICE']:
     121                # The service name exists and is of greater than zero length
     122                self.connection = Database.connect('service=%s' % settings_dict['SERVICE'])
     123            else:
     124                # Connect the normal way
     125                if settings_dict['NAME'] == '':
     126                    from django.core.exceptions import ImproperlyConfigured
     127                    raise ImproperlyConfigured("You need to specify NAME in your Django settings file.")
     128                conn_params = {
     129                    'database': settings_dict['NAME'],
     130                    }
     131                conn_params.update(settings_dict['OPTIONS'])
     132                if 'autocommit' in conn_params:
     133                    del conn_params['autocommit']
     134                if settings_dict['USER']:
     135                    conn_params['user'] = settings_dict['USER']
     136                if settings_dict['PASSWORD']:
     137                    conn_params['password'] = settings_dict['PASSWORD']
     138                if settings_dict['HOST']:
     139                    conn_params['host'] = settings_dict['HOST']
     140                if settings_dict['PORT']:
     141                    conn_params['port'] = settings_dict['PORT']
     142                self.connection = Database.connect(**conn_params)
     143
     144            # Now that the connection is created, finish up.
    137145            self.connection.set_client_encoding('UTF8')
    138146            self.connection.set_isolation_level(self.isolation_level)
    139147            connection_created.send(sender=self.__class__, connection=self)
     148
    140149        cursor = self.connection.cursor()
    141150        cursor.tzinfo_factory = None
    142151        if new_connection:
Back to Top