Module: Spider::Model::Storage::Db::Connectors::OCI8

Defined in:
lib/spiderfw/model/storage/db/connectors/oci8.rb

Defined Under Namespace

Modules: ClassMethods

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.included(klass) ⇒ Object 



7
8
9
 
# File 'lib/spiderfw/model/storage/db/connectors/oci8.rb', line 7

def self.included(klass)
    klass.extend(ClassMethods)
end

Instance Method Details

#do_commit ⇒ Object 



55
56
57
58
59
 
# File 'lib/spiderfw/model/storage/db/connectors/oci8.rb', line 55

def do_commit
    return release unless transactions_enabled?
    curr[:conn].commit if curr[:conn]
    release
end

#do_describe_table(conn, table) ⇒ Object 



178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
 
# File 'lib/spiderfw/model/storage/db/connectors/oci8.rb', line 178

def do_describe_table(conn, table)
    columns = []
    t = conn.describe_table(table)
    t.columns.each do |c|
        col = {
            :name => c.name,
            :type => c.data_type.to_s.upcase,
            :length => c.data_size,
            :precision => c.precision,
            :scale => c.scale,
            :null => c.nullable?
        }
        col.delete(:length) if (col[:precision])
        columns << col
    end
    columns
end

#do_rollback ⇒ Object 



61
62
63
64
65
 
# File 'lib/spiderfw/model/storage/db/connectors/oci8.rb', line 61

def do_rollback
    return release unless transactions_enabled?
    curr[:conn].rollback
    release
end

#do_start_transaction ⇒ Object 



45
46
47
48
 
# File 'lib/spiderfw/model/storage/db/connectors/oci8.rb', line 45

def do_start_transaction
    return unless transactions_enabled?
    connection.autocommit = false
end

#execute(sql, *bind_vars) ⇒ Object 



80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
 
# File 'lib/spiderfw/model/storage/db/connectors/oci8.rb', line 80

def execute(sql, *bind_vars)
    begin
        if (bind_vars && bind_vars.length > 0)
            debug_vars = bind_vars.map{|var| var = var.to_s; var && var.length > 50 ? var[0..50]+"...(#{var.length-50} chars more)" : var}
        end
        curr[:last_executed] = [sql, bind_vars]
        if Spider.conf.get('storage.db.replace_debug_vars')
            debug("oci8 #{connection} executing: "+sql.gsub(/:(\d+)/){
                i = $1.to_i
                v = bind_vars[i-1]
                dv = debug_vars[i-1]
                v.is_a?(String) ? "'#{dv}'" : dv
            })
        else
            debug_vars_str = debug_vars ? debug_vars.join(', ') : ''
            debug("oci8 #{connection} executing:\n#{sql}\n[#{debug_vars_str}]")
        end
        query_start
        cursor = connection.parse(sql)
        return cursor if (!cursor || cursor.is_a?(Fixnum))
        bind_vars.each_index do |i|
            var = bind_vars[i]
            if (var.is_a?(Oracle::OracleNilValue))
                cursor.bind_param(":#{i+1}", nil, var.type, 0)
            else
                cursor.bind_param(":#{i+1}", var)
            end
        end
        res = cursor.exec
        have_result = (cursor.type == ::OCI8::STMT_SELECT)
        # @cursor = connection.exec(sql, *bind_vars)
        if (have_result)
            result = []
            while (h = cursor.fetch_hash)
                h.each do |key, val|
                    if val.respond_to?(:read)
                        h[key] = val.read
                    end
                end
                if block_given?
                    yield h
                else
                    result << h
                end
            end
        end
        if (have_result)
            unless block_given?
                curr[:last_result_length] = result.length
                result.extend(StorageResult)
                return result
            end
        else
            return res
        end
        cursor.close

    rescue => exc
        curr[:conn].break if curr[:conn]
        rollback! if in_transaction?
        #curr[:conn].logoff
        release
        if (exc.message =~ /ORA-00001/)
            raise Spider::Model::Storage::DuplicateKey
        else
            raise exc
        end
    ensure
        query_finished
        cursor.close if cursor
        release if curr[:conn] && !in_transaction?
        post_execute
    end
end

#execute_statement(stmt, *bind_vars) ⇒ Object 



161
162
163
 
# File 'lib/spiderfw/model/storage/db/connectors/oci8.rb', line 161

def execute_statement(stmt, *bind_vars)
    stmt.exec(bind_vars)
end

#in_transaction? ⇒ Boolean

Returns:

  • (Boolean) 


50
51
52
53
 
# File 'lib/spiderfw/model/storage/db/connectors/oci8.rb', line 50

def in_transaction?
    return false unless transactions_enabled?
    return curr[:conn] && !curr[:conn].autocommit?
end

#prepare(sql) ⇒ Object 



156
157
158
159
 
# File 'lib/spiderfw/model/storage/db/connectors/oci8.rb', line 156

def prepare(sql)
    debug("oci8 preparing: #{sql}")
    return connection.parse(sql)
end

#prepare_value(type, value) ⇒ Object 



67
68
69
70
71
72
73
74
75
76
77
 
# File 'lib/spiderfw/model/storage/db/connectors/oci8.rb', line 67

def prepare_value(type, value)
    value = super
    type = type.primary_keys[0].type if type < Spider::Model::BaseModel
    type = Fixnum if type == Spider::DataTypes::PK
    return Oracle::OracleNilValue.new(Spider::Model.ruby_type(type)) if (value == nil)
    case type.name
    when 'Spider::DataTypes::Binary'
        return OCI8::BLOB.new(curr[:conn], value)
    end
    return value
end

#release ⇒ Object 



35
36
37
38
39
40
41
42
43
 
# File 'lib/spiderfw/model/storage/db/connectors/oci8.rb', line 35

def release
    begin
        curr[:conn].autocommit = true if curr[:conn]
        super
    rescue
        self.class.remove_connection(curr[:conn], @connection_params)
        curr[:conn] = nil
    end
end

#table_exists?(table) ⇒ Boolean

Returns:

  • (Boolean) 


166
167
168
169
170
171
172
173
174
175
176
 
# File 'lib/spiderfw/model/storage/db/connectors/oci8.rb', line 166

def table_exists?(table)
    begin
        connection do |c|
            c.describe_table(table)
        end
        Spider.logger.debug("TABLE EXISTS #{table}")
        return true
    rescue OCIError
        return false
    end
end