com.github.hackerwin7.jlib.utils.drivers.mysql.client

Class MysqlClient

java.lang.Object

com.github.hackerwin7.jlib.utils.drivers.mysql.client.MysqlClient

public class MysqlClient
extends Object

Created by IntelliJ IDEA. User: hackerwin7 Date: 2015/12/24 Time: 2:20 PM Desc: mysql jdbc client

Field Summary

Fields

Modifier and Type	Field and Description
static int	QUEUE_DEFAULT_SIZE
static int	RANDOM_INT_RANGE
static long	RANDOM_LONG_RANGE

Constructor Summary

Constructors

Constructor and Description
MysqlClient(MysqlConf conf) connect the mysql server using jdbc

Method Summary

Modifier and Type	Method and Description
MyData	desc(String tbName) desc table structure
void	execute(String sql) execute update delete or insert
void	executeBatch(List<String> sqls) execute batch
MyData	getMyData()
boolean	isDataQueueEmpty()
List<MyData>	query(String sql) query from sql , receive list MyData
void	queryAsync(String sql) query sql retrieve data into queue
void	rdInsert(String tb, int count) random insert with table name
void	setBatchSize(int batchSize) set batch size

Methods inherited from class java.lang.Object

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

Field Detail

QUEUE_DEFAULT_SIZE

public static final int QUEUE_DEFAULT_SIZE

See Also:

Constant Field Values

RANDOM_LONG_RANGE

public static final long RANDOM_LONG_RANGE

See Also:

Constant Field Values

RANDOM_INT_RANGE

public static final int RANDOM_INT_RANGE

See Also:

Constant Field Values

Constructor Detail

MysqlClient

public MysqlClient(MysqlConf conf)
            throws Exception

connect the mysql server using jdbc

Parameters:

conf -

Throws:

Exception

Method Detail

execute

public void execute(String sql)

execute update delete or insert

Parameters:

sql -

Throws:

Exception

executeBatch

public void executeBatch(List<String> sqls)

execute batch

Parameters:

sqls -

Throws:

Exception

rdInsert

public void rdInsert(String tb,
                     int count)
              throws Exception

random insert with table name

Parameters:

tb -

count -

Throws:

Exception

query

public List<MyData> query(String sql)
                   throws Exception

query from sql , receive list MyData

Parameters:

sql -

Returns:

list of MyData

Throws:

Exception

queryAsync

public void queryAsync(String sql)
                throws Exception

query sql retrieve data into queue

Parameters:

sql -

Throws:

Exception

desc

public MyData desc(String tbName)
            throws Exception

desc table structure

Parameters:

tbName -

Returns:

MyData

Throws:

Exception

setBatchSize

public void setBatchSize(int batchSize)

set batch size

Parameters:

batchSize -

getMyData

public MyData getMyData()
                 throws Exception

Throws:

Exception

isDataQueueEmpty

public boolean isDataQueueEmpty()