Um die DBD:SQLAnywhere-Schnittstelle aus einer Ruby-Anwendung verwenden zu können, müssen Sie zuerst Ruby informieren, dass Sie das Ruby-DBI-Modul verwenden möchten. Dazu schreiben Sie die nachstehende Zeile an den Anfang der Ruby-Quelldatei.

require 'dbi'

Das DBI-Modul lädt, falls erforderlich, automatisch die Schnittstelle für den SQL Anywhere-Datenbanktreiber (DBD).

In der Regel öffnen Sie eine einzelne Verbindung zu einer Datenbank und führen dann alle erforderlichen Vorgänge durch, indem Sie eine Sequenz von SQL-Anweisungen ausführen. Öffnen Sie eine Verbindung mithilfe der connect-Funktion. Der Rückgabewert ist ein Handle zur Datenbankverbindung, mit dem Sie die nachfolgenden Vorgänge in dieser Verbindung durchführen.

Der Aufruf der connect-Funktion hat die allgemeine Form:

dbh = DBI.connect('DBI:SQLAnywhere:Servername', Benutzer-ID, Kennwort, Optionen)

Um die connect-Funktion zu veranschaulichen, starten Sie den Datenbankserver und die Beispieldatenbank, bevor Sie die Ruby Beispielskripten ausführen.

dbeng12 Beispielverzeichnis\demo.db

Das nachstehende Codebeispiel öffnet und schließt eine Verbindung zur SQL Anywhere-Beispieldatenbank. Die Zeichenfolge "demo" im untenstehenden Beispiel ist der Servername.

require 'dbi'
DBI.connect('DBI:SQLAnywhere:demo', 'DBA', 'sql') do |dbh|
    if dbh.ping
       print "Successfully Connected\n"
       dbh.disconnect()
    end
end

Optional können Sie auch eine Verbindungszeichenfolge statt des Servernamens angeben. Das obenstehende Skript kann beispielsweise geändert werden, indem Sie den ersten Parameter in der connect-Funktion folgendermaßen ändern:

require 'dbi'
DBI.connect('DBI:SQLAnywhere:SERVER=demo;DBN=demo', 'DBA', 'sql') do |dbh|
    if dbh.ping
       print "Successfully Connected\n"
       dbh.disconnect()
    end
end

Die Benutzer-ID und das Kennwort können nicht in der Verbindungszeichenfolge angegeben werden. Ruby DBI füllt automatisch den Benutzernamen und das Kennwort mit Standardwerten, wenn diese Argumente ausgelassen werden. Daher sollten Sie in Ihrer Verbindungszeichenfolge niemals einen UID- oder PWD-Verbindungsparameter angeben. Wenn Sie es dennoch tun, wird eine Ausnahmebedingung generiert.

Das folgende Beispiel zeigt, wie zusätzliche Verbindungsparameter an die connect-Funktion als Hash aus Schlüsselwort/Wert-Paaren übergeben werden können.

require 'dbi'
DBI.connect('DBI:SQLAnywhere:demo', 'DBA', 'sql', 
       { :ConnectionName => "RubyDemo",
         :DatabaseFile => "demo.db",
         :DatabaseName => "demo" }
        ) do |dbh|
    if dbh.ping
       print "Successfully Connected\n"
       dbh.disconnect()
    end
end

Nachdem Sie ein Handle für eine offene Verbindung erhalten haben, können Sie auf die Daten in der Datenbank zugreifen und sie ändern. Der einfachste Vorgang ist dabei, einige Zeilen abzurufen und auszudrucken.

Zuerst muss eine SQL-Anweisung ausgeführt werden. Wenn die Anweisung eine Ergebnismenge zurückgibt, verwenden Sie das resultierende Anweisungs-Handle, um Metainformationen über die Ergebnismenge und die Zeilen der Ergebnismenge abzurufen. Das folgende Beispiel bezieht die Spaltennamen aus den Metadaten und zeigt die Spaltennamen und die Werte für jede abgerufene Zeile an.

require 'dbi'

def db_query( dbh, sql )
    sth = dbh.execute(sql)
    print "# of Fields:  #{sth.column_names.size}\n"
    sth.fetch do |row|
        print "\n"
        sth.column_info.each_with_index do |info, i|
            unless info["type_name"] == "LONG VARBINARY"
                print "#{info["name"]}=#{row[i]}\n" 
            end
        end
    end
    sth.finish
end

begin
    dbh = DBI.connect('DBI:SQLAnywhere:demo', 'DBA', 'sql')
    db_query(dbh, "SELECT * FROM Products")
rescue DBI::DatabaseError => e
    puts "An error occurred"
    puts "Error code: #{e.err}"
    puts "Error message: #{e.errstr}"
    puts "Error SQLSTATE: #{e.state}"
ensure
    dbh.disconnect if dbh
end

Die ersten paar Zeilen der Ausgabe, die angezeigt werden, finden Sie untenstehend.

# of Fields:  8

ID=300
Name=Tee Shirt
Description=Tank Top
Size=Small
Color=White
Quantity=28
UnitPrice=9.00

ID=301
Name=Tee Shirt
Description=V-neck
Size=Medium
Color=Orange
Quantity=54
UnitPrice=14.00

Es ist wichtig, "finish" aufzurufen, um das Anweisungs-Handle freizugeben, wenn Sie fertig sind. Wenn Sie dies nicht tun, erhalten Sie möglicherweise einen Fehler wie den folgenden:

Resource governor for 'prepared statements' exceeded

Um Handle-Leaks zu erkennen, begrenzt der SQL Anywhere-Datenbankserver standardmäßig die Anzahl von Cursorn und vorbereiteten Anweisungen auf maximal 50 pro Verbindung. Der Ressourcenwächter generiert automatisch einen Fehler, wenn diese Grenzwerte überschritten werden. Wenn dieser Fehler auftritt, suchen Sie nach nicht entfernten Anweisungshandles. Verwenden Sie prepare_cached mit Bedacht, da die Anweisungshandles nicht entfernt werden.

Erforderlichenfalls können Sie diese Grenzwerte ändern, indem Sie die Optionen max_cursor_count und max_statement_count definieren. Siehe max_cursor_count-Option und max_statement_count-Option.

Zum Einfügen von Zeilen wird ein Handle für eine offene Verbindung benötigt. Die einfachste Methode, Zeilen einzufügen, besteht darin, eine parametrisierte INSERT-Anweisung zu verwenden, in der Fragezeichen als Platzhalter für Werte eingesetzt werden. Die Anweisung wird erst vorbereitet und dann pro neuer Zeile ausgeführt. Die neuen Zeilenwerte werden als Parameter an die execute-Methode übergeben.

require 'dbi'

def db_query( dbh, sql )
    sth = dbh.execute(sql)
    print "# of Fields:  #{sth.column_names.size}\n"
    sth.fetch do |row|
        print "\n"
        sth.column_info.each_with_index do |info, i|
            unless info["type_name"] == "LONG VARBINARY"
                print "#{info["name"]}=#{row[i]}\n" 
            end
        end
    end
    sth.finish
end

def db_insert( dbh, rows )
    sql = "INSERT INTO Customers (ID, GivenName, Surname,
                Street, City, State, Country, PostalCode,
                Phone, CompanyName)
           VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"
    sth = dbh.prepare(sql);
    rows.each do |row|
        sth.execute(row[0],row[1],row[2],row[3],row[4],
                    row[5],row[6],row[7],row[8],row[9])
    end
end

begin
    dbh = DBI.connect('DBI:SQLAnywhere:demo', 'DBA', 'sql')
    rows = [
        [801,'Alex','Alt','5 Blue Ave','New York','NY','USA',
            '10012','5185553434','BXM'],
        [802,'Zach','Zed','82 Fair St','New York','NY','USA',
            '10033','5185552234','Zap']
       ]
    db_insert(dbh, rows)
    dbh.commit
    db_query(dbh, "SELECT * FROM Customers WHERE ID > 800")
rescue DBI::DatabaseError => e
    puts "An error occurred"
    puts "Error code: #{e.err}"
    puts "Error message: #{e.errstr}"
    puts "Error SQLSTATE: #{e.state}"
ensure
    dbh.disconnect if dbh
end