org.wandora.utils.sqlproxy

Class SQLProxyClient

java.lang.Object

org.wandora.utils.sqlproxy.SQLProxyClient

public class SQLProxyClient
extends java.lang.Object

Author:

olli

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	charset
private boolean	compress
private java.lang.String	databaseFlavour
private java.io.PushbackReader	inReader
private java.io.Writer	outWriter
private java.net.Socket	socket
private boolean	useSSL

Constructor Summary

Constructors

Constructor and Description
SQLProxyClient() Creates a new instance of SQLProxyClient

Method Summary

Modifier and Type	Method and Description
void	close()
void	compress()
void	connect(java.lang.String host)
void	connect(java.lang.String host, int port)
void	connect(java.lang.String host, int port, boolean useSSL)
static SQLProxyClient	createProxy(java.lang.String connectionString, java.lang.String user, java.lang.String password) sqlproxy:hostname[:port][/database][?param1=value1¶m2=value2] params: compress[=true|false] (default false, if param is specified without value, true is assumed) flavour=mysql|generic (note this is not actually used in any way in SQLProxyClient, only stored for application use) usessl[=true|false] (default false, if param is specified without value, true is assumed)
void	executeCommand(java.lang.String cmd)
java.util.Collection<java.util.Map<java.lang.String,java.lang.Object>>	executeQuery(java.lang.String query)
int	executeUpdate(java.lang.String update)
private void	finishCompressedStream()
java.lang.String	getFlavour()
boolean	login(java.lang.String user, java.lang.String pass)
static void	main(java.lang.String[] args)
boolean	open(java.lang.String database)
private Tuples.T2<java.lang.Double,java.lang.Boolean>	readDouble()
private Tuples.T2<java.lang.Integer,java.lang.Boolean>	readInteger()
private java.lang.String	readLine()
private java.util.Collection<java.util.Map<java.lang.String,java.lang.Object>>	readResultSet()
private Tuples.T2<java.lang.String,java.lang.Boolean>	readString()
int	readUpdateCount()
void	setFlavour(java.lang.String f)
void	setUseSSL(boolean b)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

useSSL

private boolean useSSL

socket

private java.net.Socket socket

outWriter

private java.io.Writer outWriter

inReader

private java.io.PushbackReader inReader

charset

private java.lang.String charset

compress

private boolean compress

databaseFlavour

private java.lang.String databaseFlavour

Constructor Detail

SQLProxyClient

public SQLProxyClient()

Creates a new instance of SQLProxyClient

Method Detail

createProxy

public static SQLProxyClient createProxy(java.lang.String connectionString,
                                         java.lang.String user,
                                         java.lang.String password)
                                  throws java.io.IOException,
                                         SQLProxyException

sqlproxy:hostname[:port][/database][?param1=value1¶m2=value2] params: compress[=true|false] (default false, if param is specified without value, true is assumed) flavour=mysql|generic (note this is not actually used in any way in SQLProxyClient, only stored for application use) usessl[=true|false] (default false, if param is specified without value, true is assumed)

Throws:

java.io.IOException

SQLProxyException

getFlavour

public java.lang.String getFlavour()

setFlavour

public void setFlavour(java.lang.String f)

connect

public void connect(java.lang.String host)
             throws java.io.IOException

Throws:

java.io.IOException

connect

public void connect(java.lang.String host,
                    int port)
             throws java.io.IOException

Throws:

java.io.IOException

connect

public void connect(java.lang.String host,
                    int port,
                    boolean useSSL)
             throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

setUseSSL

public void setUseSSL(boolean b)

readLine

private java.lang.String readLine()
                           throws java.io.IOException

Throws:

java.io.IOException

readString

private Tuples.T2<java.lang.String,java.lang.Boolean> readString()
                                                          throws java.io.IOException,
                                                                 SQLProxyException

Throws:

java.io.IOException

SQLProxyException

readInteger

private Tuples.T2<java.lang.Integer,java.lang.Boolean> readInteger()
                                                            throws java.io.IOException,
                                                                   SQLProxyException

Throws:

java.io.IOException

SQLProxyException

readDouble

private Tuples.T2<java.lang.Double,java.lang.Boolean> readDouble()
                                                          throws java.io.IOException,
                                                                 SQLProxyException

Throws:

java.io.IOException

SQLProxyException

readResultSet

private java.util.Collection<java.util.Map<java.lang.String,java.lang.Object>> readResultSet()
                                                                                      throws java.io.IOException,
                                                                                             SQLProxyException

Throws:

java.io.IOException

SQLProxyException

readUpdateCount

public int readUpdateCount()
                    throws java.io.IOException,
                           SQLProxyException

Throws:

java.io.IOException

SQLProxyException

compress

public void compress()
              throws java.io.IOException,
                     SQLProxyException

Throws:

java.io.IOException

SQLProxyException

login

public boolean login(java.lang.String user,
                     java.lang.String pass)
              throws java.io.IOException

Throws:

java.io.IOException

open

public boolean open(java.lang.String database)
             throws java.io.IOException

Throws:

java.io.IOException

executeCommand

public void executeCommand(java.lang.String cmd)
                    throws java.io.IOException,
                           SQLProxyException

Throws:

java.io.IOException

SQLProxyException

finishCompressedStream

private void finishCompressedStream()
                             throws java.io.IOException

Throws:

java.io.IOException

executeQuery

public java.util.Collection<java.util.Map<java.lang.String,java.lang.Object>> executeQuery(java.lang.String query)
                                                                                    throws java.io.IOException,
                                                                                           SQLProxyException

Throws:

java.io.IOException

SQLProxyException

executeUpdate

public int executeUpdate(java.lang.String update)
                  throws java.io.IOException,
                         SQLProxyException

Throws:

java.io.IOException

SQLProxyException

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception