Changeset 9250
- Timestamp:
- 05/03/08 04:35:26 (5 months ago)
- Files:
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
adapters/informix/lib/active_record/connection_adapters/informix_adapter.rb
r8320 r9250 1 # $Id: informix_adapter.rb,v 1.1 5 2007/12/06 01:43:11santana Exp $2 3 # Copyright (c) 2006-200 7, Gerardo Santana Gomez Garrido <gerardo.santana@gmail.com>1 # $Id: informix_adapter.rb,v 1.18 2008/04/16 14:51:34 santana Exp $ 2 3 # Copyright (c) 2006-2008, Gerardo Santana Gomez Garrido <gerardo.santana@gmail.com> 4 4 # All rights reserved. 5 5 # … … 52 52 value = self[c.name] 53 53 next if ![:text, :binary].include? c.type || value.nil? || value == '' 54 connection.raw_connection. prepare(<<-end_sql) do |stmt|54 connection.raw_connection.execute(<<-end_sql, StringIO.new(value)) 55 55 UPDATE #{self.class.table_name} SET #{c.name} = ? 56 56 WHERE #{self.class.primary_key} = #{quote_value(id)} 57 end_sql 58 stmt.execute(StringIO.new(value)) 59 end 57 end_sql 60 58 end 61 59 end … … 102 100 end 103 101 104 # This adapter requires the Informix driver for Ruby102 # This adapter requires Ruby/Informix 105 103 # http://ruby-informix.rubyforge.org 106 104 # … … 114 112 def initialize(db, logger) 115 113 super 116 @ifx_version = db.prepare(<<-end_sql) do |stmt| 117 SELECT dbinfo('version', 'major') version FROM systables 118 WHERE tabid = 1 119 end_sql 120 stmt.execute['version'].to_i 121 end 114 @ifx_version = db.version.major.to_i 122 115 end 123 116 … … 167 160 168 161 def execute(sql, name = nil) 169 log(sql, name) { @connection. execute(sql) }162 log(sql, name) { @connection.immediate(sql) } 170 163 end 171 164 … … 175 168 176 169 def insert(sql, name= nil, pk= nil, id_value= nil, sequence_name = nil) 177 log(sql, name) { @connection.execute(sql) }170 execute(sql) 178 171 id_value 179 172 end … … 183 176 184 177 def begin_db_transaction 185 @connection.execute("begin work")178 execute("begin work") 186 179 end 187 180 … … 243 236 244 237 def drop_database(name) 245 @connection.execute("drop database #{name}")238 execute("drop database #{name}") 246 239 end 247 240 248 241 def create_database(name) 249 @connection.execute("create database #{name}")242 execute("create database #{name}") 250 243 end 251 244