Class: FluidDb::Mysql

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

Instance Attribute Summary

Attributes inherited from Base

#connection, #verbose

Instance Method Summary collapse

Methods inherited from Base

#Begin, #Commit, #Rollback, #convertTupleToHash, #escape_string, #format_to_sql, #initialize, #reconnect, #splice_sql, #verboseLog

Constructor Details

This class inherits a constructor from FluidDb::Base

Instance Method Details

#close ⇒ Object 



18
19
20
 
# File 'lib/FluidDb/Mysql.rb', line 18

def close
    @connection.close
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



11
12
13
14
15
16
 
# File 'lib/FluidDb/Mysql.rb', line 11

def connect()
    uri = @uri
    database = uri.path.sub( "/", "" )
    
    @connection = ::Mysql.new uri.host, uri.user, uri.password, database, nil, nil, ::Mysql::CLIENT_FOUND_ROWS
end

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



93
94
95
96
97
98
99
100
101
102
 
# File 'lib/FluidDb/Mysql.rb', line 93

def execute( sql, params=[], expected_affected_rows=nil )
    sql = self.format_to_sql( sql, params )
    #            puts "sql: #{sql}"
    @connection.query( sql );
    
    if !expected_affected_rows.nil? and
        @connection.affected_rows != expected_affected_rows then
        raise ExpectedAffectedRowsError.new( "Expected affected rows, #{expected_affected_rows}, Actual affected rows, #{@connection.affected_rows}")
    end
end

#insert(sql, params) ⇒ Object 



104
105
106
107
 
# File 'lib/FluidDb/Mysql.rb', line 104

def insert( sql, params )
    self.execute( sql, params )
    return @connection.insert_id
end

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



22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
 
# File 'lib/FluidDb/Mysql.rb', line 22

def queryForArray( 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.num_rows
        when -1
        raise FluidDb::ConnectionError.new
        when 0
        raise FluidDb::NoDataFoundError.new
        when 1
        r = results.fetch_hash
        return r
        else
        raise FluidDb::TooManyRowsError.new
    end
    
end

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



71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
 
# File 'lib/FluidDb/Mysql.rb', line 71

def queryForResultset( 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.num_rows
        when -1
        raise FluidDb::ConnectionError.new
        else
        list = Array.new
        results.each_hash do |row|
            list.push row
        end
        
        return list
    end
end

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



45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
 
# File 'lib/FluidDb/Mysql.rb', line 45

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.num_rows
        when -1
        raise FluidDb::ConnectionError.new
        when 0
        raise FluidDb::NoDataFoundError.new
        when 1
        r=nil;
        results.each do |row|
            r=row
        end
        return r[0]
        else
        raise FluidDb::TooManyRowsError.new
    end
    
end