Connection to the database via the TCP protocol. More...

Inheritance diagram for Deveel.Data.Client.TCPStreamDatabaseInterface:

Package Functions
	TCPStreamDatabaseInterface (String host, int port, string initial_database)

void	ConnectToDatabase ()
	Connects to the database. More...

Package Functions inherited from Deveel.Data.Client.StreamDatabaseInterface
	StreamDatabaseInterface (string initial_database)

void	Setup (Stream rawin, Stream rawout)
	Sets up the stream connection with the given input/output stream. More...

Private Attributes
readonly String	host
	The name of the host we are connected to. More...

readonly int	port
	The port we are connected to. More...

Socket	socket
	The Socket connection. More...

Additional Inherited Members
Protected Member Functions inherited from Deveel.Data.Client.StreamDatabaseInterface
override void	SendCommand (byte[] command, int offset, int size)

override byte[]	ReceiveCommand (int timeout)

override void	CloseConnection ()

Protected Attributes inherited from Deveel.Data.Client.StreamDatabaseInterface
BinaryWriter	output
	The data output stream for the db protocol. More...

BinaryReader	input
	The data input stream for the db protocol. More...

Detailed Description

Connection to the database via the TCP protocol.

Definition at line 25 of file TCPStreamDatabaseInterface.cs.

Constructor & Destructor Documentation

Deveel.Data.Client.TCPStreamDatabaseInterface.TCPStreamDatabaseInterface	(	String	host,
		int	port,
		string	initial_database
	)

inlinepackage

Definition at line 41 of file TCPStreamDatabaseInterface.cs.

             : base(initial_database) {
             this.host = host;
             this.port = port;
         }

Member Function Documentation

void Deveel.Data.Client.TCPStreamDatabaseInterface.ConnectToDatabase ( )

inlinepackage

Connects to the database.

Definition at line 50 of file TCPStreamDatabaseInterface.cs.

                                           {
             if (socket != null) {
                 throw new DataException("Connection already established.");
             }
             try {
                 // Open a socket connection to the server.
                 socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                 socket.Connect(host, port);
                 // Setup the stream with the given input and output streams.
                 Setup(new NetworkStream(socket, FileAccess.Read), new NetworkStream(socket, FileAccess.Write));
             } catch (IOException e) {
                 throw new DataException(e.Message);
             }
         }