Class: FluidDb::Firebird

Inherits:
Base
  • Object
show all
Defined in:
lib/FluidDb/Firebird.rb

Instance Attribute Summary

Attributes inherited from Base

#connection, #verbose

Instance Method Summary collapse

Methods inherited from Base

#convertTupleToHash, #escape_string, #format_to_sql, #initialize, #reconnect, #splice_sql, #verboseLog

Constructor Details

This class inherits a constructor from FluidDb::Base

Instance Method Details

#Begin ⇒ Object

Transaction Semantics



145
146
147
 
# File 'lib/FluidDb/Firebird.rb', line 145

def Begin
    @connection.transaction()
end

#close ⇒ Object 



36
37
38
 
# File 'lib/FluidDb/Firebird.rb', line 36

def close
    @connection.close
end

#Commit ⇒ Object

Transaction Semantics



150
151
152
 
# File 'lib/FluidDb/Firebird.rb', line 150

def Commit
    @connection.commit()
end

#connect ⇒ Object

Connect to Db.

Parameters:

  • uri (String) —

    a location for the resource to which we will attach, eg mysql://user:[email protected]/foo



12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
 
# File 'lib/FluidDb/Firebird.rb', line 12

def connect()
    uri = @uri
    
    user = uri.user || "sysdba"
    password = uri.password || "masterkey"
    port = uri.port || 3050

    path = uri.path
    path = path.slice(1,uri.path.length-1) if path.slice(0,3) == "/C:"
    path = URI.unescape( path )

    
    # The Database class acts as a factory for Connections.
    # It can also create and drop databases.
    db = Database.new(
                      :database => "#{uri.host}/#{port}:#{path}",
                      :username => user,
                      :password => password)
    # :database is the only parameter without a default.
    # Let's connect to the database, creating it if it doesn't already exist.
    @connection = db.connect rescue db.create.connect

end

#exec_params(sql, params, expected_affected_rows = nil) ⇒ Object 



119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
 
# File 'lib/FluidDb/Firebird.rb', line 119

def exec_params( sql, params, expected_affected_rows=nil )
                parts = sql.split( "?" )
    sql = ""
    parts.each_with_index do |p,idx|
        sql = sql + p;
        sql = sql + "$#{idx+1}" if idx < parts.length - 1
    end
    affected_rows = @connection.exec_params( sql, params );
    
    if !expected_affected_rows.nil? and
        affected_rows != expected_affected_rows then
        raise ExpectedAffectedRowsError.new( "Expected affected rows, #{expected_affected_rows}, Actual affected rows, #{affected_rows}")
    end
#            rescue PG::Error => e
#            raise DuplicateKeyError.new( e.message ) unless e.message.index( "duplicate key value violates unique constraint" ).nil?
    
#            raise e
end

#execute(sql, params = [], expected_affected_rows = nil) ⇒ Object 



103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
 
# File 'lib/FluidDb/Firebird.rb', line 103

def execute( sql, params=[], expected_affected_rows=nil )
    sql = self.format_to_sql( sql, params )
    
    self.verboseLog( "#{self.class.name}.execute. #{sql}" )
    affected_rows = @connection.execute(sql)

    if !expected_affected_rows.nil? and
        affected_rows != expected_affected_rows then
        raise ExpectedAffectedRowsError.new( "Expected affected rows, #{expected_affected_rows}, Actual affected rows, #{affected_rows}")
    end
#            rescue PG::Error => e
#                raise DuplicateKeyError.new( e.message ) unless e.message.index( "duplicate key value violates unique constraint" ).nil?
    
#                raise e
end

#insert(sql, params) ⇒ Object 



138
139
140
141
142
 
# File 'lib/FluidDb/Firebird.rb', line 138

def insert( sql, params )
    raise "Pgsql uses SEQUENCES, so possibly easier to use 2 executes"
    #            self.execute( sql, params )
    #return @connection.last_id
end

#queryForArray(sql, params = []) ⇒ Object 



40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
 
# File 'lib/FluidDb/Firebird.rb', line 40

def queryForArray( sql, params=[] )
    sql = self.format_to_sql( sql, params )
    list = @connection.query(:hash, sql)

    #        if ( $result === false ) then
    #    $message = pg_last_error( $this->connection );
    #    throw new Fluid_ConnectionException( $message );
    #end

    case list.length
        when -1
        raise FluidDb::ConnectionError.new
        when 0
        raise FluidDb::NoDataFoundError.new
        when 1
        return list[0]
        else
        raise FluidDb::TooManyRowsError.new
    end
end

#queryForResultset(sql, params = []) ⇒ Object 



84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
 
# File 'lib/FluidDb/Firebird.rb', line 84

def queryForResultset( sql, params=[] )
    sql = self.format_to_sql( sql, params )
    list = @connection.query(:hash, sql)
    
    #        if ( $result === false ) then
    #    $message = pg_last_error( $this->connection );
    #    throw new Fluid_ConnectionException( $message );
    #end
    
    case list.length
        when -1
        raise FluidDb::ConnectionError.new
        else
        
        return list
    end
end

#queryForValue(sql, params = []) ⇒ Object 



61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
 
# File 'lib/FluidDb/Firebird.rb', line 61

def queryForValue( sql, params=[] )
    sql = self.format_to_sql( sql, params )
    results = @connection.query(sql)
    
    #        if ( $result === false ) then
    #    $message = pg_last_error( $this->connection );
    #    throw new Fluid_ConnectionException( $message );
    #end
    case results.length
        when -1
        raise FluidDb::ConnectionError.new
        when 0
        raise FluidDb::NoDataFoundError.new
        when 1
        return results[0][0]
        #                return results.getvalue(0,0)
        else
        raise FluidDb::TooManyRowsError.new
    end
    
end

#Rollback ⇒ Object

Transaction Semantics



155
156
157
 
# File 'lib/FluidDb/Firebird.rb', line 155

def Rollback
    @connection.rollback()
end