MySQL

JdmConnection>>initializeConnection
        | a |
        packetClass _ JdmInputPacket.
        a _ self class protocolHashes.
        (hashesByProtocol _ Dictionary new)
                at: (a at: 1) put: (a at: 2);
                at: (a at: 3) put: (a at: 4).

        socket _ Socket new
                connectTo: (connectionSpec host)
                port: (connectionSpec port).
        socket waitForConnectionFor: Socket standardDeadline.

        readStream _ writeStream _ SocketStream on: socket.

        serverInfo _ JdmServerInfo on: self.
        serverInfo serverVersion >= self class largeSizesVersion
                ifTrue: [packetClass _ JdmLargeSizeInputPacket].

        clientCapabilities _ serverInfo protocol = 10 ifTrue: [1] ifFalse: [0]

Příklad

Socket initializeNetwork.

spec :=    (JdmConnectionSpec new initialize
        user: 'root'; password: '';
        host: (NetNameResolver addressForName: 'localhost');
        database: 'test';
        port: 3306).

connection := JdmConnection on: spec.

statement := connection createStatement.
resultSet := statement executeQuery: 'select * from testtable'.

"resultSet inspect"

"Jmena sloupcu"
Transcript cr; show: (resultSet columns collect: [:col | col name]) asString.

[resultSet next] whileTrue:
[
	value := resultSet valueNamed: 'Name'. "hodnota sloupce Name"
	Transcript cr; show: value printString.
].

connection close.

Odkaz na tuto stránku

• Databázová konektivita, poslední úprava dne 10 Březen 2004 v 21:01:51 uživatelem gprs40-93.eurotel.cz