| 1 | """
|
|---|
| 2 | Oracle database backend for Django.
|
|---|
| 3 |
|
|---|
| 4 | Requires cx_Oracle: http://www.computronix.com/utilities.shtml
|
|---|
| 5 | """
|
|---|
| 6 |
|
|---|
| 7 | from django.core.db import base, typecasts
|
|---|
| 8 | import cx_Oracle as Database
|
|---|
| 9 |
|
|---|
| 10 | #needed for fetchone, fetchmany, fetchall support
|
|---|
| 11 | from django.core.db.dicthelpers import *
|
|---|
| 12 |
|
|---|
| 13 |
|
|---|
| 14 | DatabaseError = Database.DatabaseError
|
|---|
| 15 |
|
|---|
| 16 | class DatabaseWrapper:
|
|---|
| 17 | def __init__(self):
|
|---|
| 18 | self.connection = None
|
|---|
| 19 | self.queries = []
|
|---|
| 20 |
|
|---|
| 21 | def cursor(self):
|
|---|
| 22 | from django.conf.settings import DATABASE_USER, DATABASE_NAME, DATABASE_HOST, DATABASE_PASSWORD, DEBUG
|
|---|
| 23 | if self.connection is None:
|
|---|
| 24 | if DATABASE_NAME == '' or DATABASE_USER == '' or DATABASE_PASSWORD == '':
|
|---|
| 25 | from django.core.exceptions import ImproperlyConfigured
|
|---|
| 26 | raise ImproperlyConfigured, "You need to specify DATABASE_NAME, DATABASE_USER, and DATABASE_PASSWORD in your Django settings file."
|
|---|
| 27 | conn_string = "%s/%s@%s" % (DATABASE_USER, DATABASE_PASSWORD, DATABASE_NAME)
|
|---|
| 28 | self.connection = Database.connect(conn_string)
|
|---|
| 29 | return FormatStylePlaceholderCursor(self.connection)
|
|---|
| 30 |
|
|---|
| 31 | def commit(self):
|
|---|
| 32 | self.connection.commit()
|
|---|
| 33 |
|
|---|
| 34 | def rollback(self):
|
|---|
| 35 | if self.connection:
|
|---|
| 36 | self.connection.rollback()
|
|---|
| 37 |
|
|---|
| 38 | def close(self):
|
|---|
| 39 | if self.connection is not None:
|
|---|
| 40 | self.connection.close()
|
|---|
| 41 | self.connection = None
|
|---|
| 42 |
|
|---|
| 43 | class FormatStylePlaceholderCursor(Database.Cursor):
|
|---|
| 44 | """
|
|---|
| 45 | Django uses "format" (e.g. '%s') style placeholders, but Oracle uses ":var" style.
|
|---|
| 46 | This fixes it -- but note that if you want to use a literal "%s" in a query,
|
|---|
| 47 | you'll need to use "%%s" (which I belive is true of other wrappers as well).
|
|---|
| 48 | """
|
|---|
| 49 |
|
|---|
| 50 | def execute(self, query, params=[]):
|
|---|
| 51 | query = self.convert_arguments(query, len(params))
|
|---|
| 52 | return Database.Cursor.execute(self, query, params)
|
|---|
| 53 |
|
|---|
| 54 | def executemany(self, query, params=[]):
|
|---|
| 55 | query = self.convert_arguments(query, len(params[0]))
|
|---|
| 56 | return Database.Cursor.executemany(self, query, params)
|
|---|
| 57 |
|
|---|
| 58 | def convert_arguments(self, query, num_params):
|
|---|
| 59 | # replace occurances of "%s" with ":arg" - Oracle requires colons for parameter placeholders.
|
|---|
| 60 | args = [':arg' for i in range(num_params)]
|
|---|
| 61 | return query % tuple(args)
|
|---|
| 62 |
|
|---|
| 63 | def get_last_insert_id(cursor, table_name, pk_name):
|
|---|
| 64 | query = "SELECT %s_sq.currval from dual" % table_name
|
|---|
| 65 | cursor.execute(query)
|
|---|
| 66 | return cursor.fetchone()[0]
|
|---|
| 67 |
|
|---|
| 68 | def get_date_extract_sql(lookup_type, table_name):
|
|---|
| 69 | raise NotImplementedError
|
|---|
| 70 |
|
|---|
| 71 | def get_date_trunc_sql(lookup_type, field_name):
|
|---|
| 72 | raise NotImplementedError
|
|---|
| 73 |
|
|---|
| 74 | def get_table_list(cursor):
|
|---|
| 75 | "Returns a list of table names in the current database."
|
|---|
| 76 | raise NotImplementedError
|
|---|
| 77 |
|
|---|
| 78 | def get_relations(cursor, table_name):
|
|---|
| 79 | """
|
|---|
| 80 | Returns a dictionary of {field_index: (field_index_other_table, other_table)}
|
|---|
| 81 | representing all relationships to the given table. Indexes are 0-based.
|
|---|
| 82 | """
|
|---|
| 83 | raise NotImplementedError
|
|---|
| 84 |
|
|---|
| 85 |
|
|---|
| 86 | OPERATOR_MAPPING = {
|
|---|
| 87 | 'exact': '=',
|
|---|
| 88 | 'iexact': 'LIKE',
|
|---|
| 89 | 'contains': 'LIKE',
|
|---|
| 90 | 'icontains': 'LIKE',
|
|---|
| 91 | 'ne': '!=',
|
|---|
| 92 | 'gt': '>',
|
|---|
| 93 | 'gte': '>=',
|
|---|
| 94 | 'lt': '<',
|
|---|
| 95 | 'lte': '<=',
|
|---|
| 96 | 'startswith': 'LIKE',
|
|---|
| 97 | 'endswith': 'LIKE',
|
|---|
| 98 | 'istartswith': 'LIKE',
|
|---|
| 99 | 'iendswith': 'LIKE',
|
|---|
| 100 | }
|
|---|
| 101 |
|
|---|
| 102 | # This dictionary maps Field objects to their associated MySQL column
|
|---|
| 103 | # types, as strings. Column-type strings can contain format strings; they'll
|
|---|
| 104 | # be interpolated against the values of Field.__dict__ before being output.
|
|---|
| 105 | # If a column type is set to None, it won't be included in the output.
|
|---|
| 106 | DATA_TYPES = {
|
|---|
| 107 | 'AutoField': 'number(38)',
|
|---|
| 108 | 'BooleanField': 'number(1)',
|
|---|
| 109 | 'CharField': 'varchar2(%(maxlength)s)',
|
|---|
| 110 | 'CommaSeparatedIntegerField': 'varchar2(%(maxlength)s)',
|
|---|
| 111 | 'DateField': 'date',
|
|---|
| 112 | 'DateTimeField': 'date',
|
|---|
| 113 | 'EmailField': 'varchar2(75)',
|
|---|
| 114 | 'FileField': 'varchar2(100)',
|
|---|
| 115 | 'FloatField': 'number(%(max_digits)s, %(decimal_places)s)',
|
|---|
| 116 | 'ImageField': 'varchar2(100)',
|
|---|
| 117 | 'IntegerField': 'integer',
|
|---|
| 118 | 'IPAddressField': 'char(15)',
|
|---|
| 119 | 'ManyToManyField': None,
|
|---|
| 120 | 'NullBooleanField': 'integer',
|
|---|
| 121 | 'OneToOneField': 'integer',
|
|---|
| 122 | 'PhoneNumberField': 'varchar(20)',
|
|---|
| 123 | 'PositiveIntegerField': 'integer',
|
|---|
| 124 | 'PositiveSmallIntegerField': 'smallint',
|
|---|
| 125 | 'SlugField': 'varchar(50)',
|
|---|
| 126 | 'SmallIntegerField': 'smallint',
|
|---|
| 127 | 'TextField': 'long',
|
|---|
| 128 | 'TimeField': 'timestamp',
|
|---|
| 129 | 'URLField': 'varchar(200)',
|
|---|
| 130 | 'USStateField': 'varchar(2)',
|
|---|
| 131 | 'XMLField': 'long',
|
|---|
| 132 | }
|
|---|
| 133 |
|
|---|
| 134 | # Maps type codes to Django Field types.
|
|---|
| 135 | DATA_TYPES_REVERSE = {
|
|---|
| 136 | 16: 'BooleanField',
|
|---|
| 137 | 21: 'SmallIntegerField',
|
|---|
| 138 | 23: 'IntegerField',
|
|---|
| 139 | 25: 'TextField',
|
|---|
| 140 | 869: 'IPAddressField',
|
|---|
| 141 | 1043: 'CharField',
|
|---|
| 142 | 1082: 'DateField',
|
|---|
| 143 | 1083: 'TimeField',
|
|---|
| 144 | 1114: 'DateTimeField',
|
|---|
| 145 | 1184: 'DateTimeField',
|
|---|
| 146 | 1266: 'TimeField',
|
|---|
| 147 | 1700: 'FloatField',
|
|---|
| 148 | }
|
|---|
| 149 |
|
|---|
| 150 | EMPTY_STR_EQUIV = ' '
|
|---|