org.gridgain.jdbc.util

Class GridJdbcUtils

java.lang.Object

org.gridgain.jdbc.util.GridJdbcUtils

Direct Known Subclasses:

JU

public class GridJdbcUtils
extends Object

Utility methods for JDBC driver.

Constructor Summary

Constructors

Constructor and Description
GridJdbcUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static byte[]	marshalArgument(Map<String,Object> args) Marshals task argument to byte array.
static boolean	nullable(String name, String cls) Determines whether type is nullable.
static Map<String,Object>	taskArgument(UUID nodeId, String cacheName, String sql, long timeout, Object[] args, int pageSize, int maxRows) Creates task argument for first execution.
static Map<String,Object>	taskArgument(UUID nodeId, UUID futId, int pageSize, int maxRows) Creates task argument.
static int	type(String cls) Converts Java class name to type from Types.
static String	typeName(String cls) Converts Java class name to SQL type name.
static <T> T	unmarshal(byte[] bytes) Unmarshals object from byte array.
static SQLException	unmarshalError(byte[] bytes) Unmarshals exception from byte array.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridJdbcUtils

public GridJdbcUtils()

Method Detail

marshalArgument

public static byte[] marshalArgument(Map<String,Object> args)
                              throws SQLException

Marshals task argument to byte array.

Parameters:

args - Task argument.

Returns:

Byte array.

Throws:

SQLException - In marshalling failed.

unmarshalError

public static SQLException unmarshalError(byte[] bytes)
                                   throws SQLException

Unmarshals exception from byte array.

Parameters:

bytes - Byte array.

Returns:

Exception.

Throws:

SQLException - If unmarshalling failed.

unmarshal

public static <T> T unmarshal(byte[] bytes)
                   throws SQLException

Unmarshals object from byte array.

Parameters:

bytes - Byte array.

Returns:

Object.

Throws:

SQLException - If unmarshalling failed.

taskArgument

public static Map<String,Object> taskArgument(UUID nodeId,
                              String cacheName,
                              String sql,
                              long timeout,
                              Object[] args,
                              int pageSize,
                              int maxRows)

Creates task argument for first execution.

Parameters:

nodeId - Node ID.

cacheName - Cache name.

sql - SQL query.

timeout - Query timeout.

args - Query arguments.

pageSize - Page size.

maxRows - Maximum number of rows.

Returns:

Task argument.

taskArgument

public static Map<String,Object> taskArgument(UUID nodeId,
                              UUID futId,
                              int pageSize,
                              int maxRows)

Creates task argument.

Parameters:

nodeId - Node ID.

futId - Future ID.

pageSize - Page size.

maxRows - Maximum number of rows.

Returns:

Task argument.

type

public static int type(String cls)

Converts Java class name to type from Types.

Parameters:

cls - Java class name.

Returns:

Type from Types.

typeName

public static String typeName(String cls)

Converts Java class name to SQL type name.

Parameters:

cls - Java class name.

Returns:

SQL type name.

nullable

public static boolean nullable(String name,
               String cls)

Determines whether type is nullable.

Parameters:

name - Column name.

cls - Java class name.

Returns:

True if nullable.