Package ai.starlake.jdbc

Class StarlakeSession

java.lang.Object

ai.starlake.jdbc.StarlakeSession

public class StarlakeSession
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	StarlakeSession.Status

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BASE62
final ai.starlake.jdbc.DBObjects	dbObjects
static final Logger	LOGGER

Constructor Summary

Constructors

Constructor	Description
StarlakeSession(StarlakeConnection conn, String id, Map<String,String> options)
StarlakeSession(StarlakeConnection conn, Map<String,String> options)

Method Summary

Modifier and Type	Method	Description
void	apply(Map<String,String> options)
static Map<String,String>	connectionProperties(String jdbcUrl)	Extracts the values of "db" and "schema" from a JDBC URL.
void	drop(Map<String,String> options)
static String	generateUniqueID()
Instant	getEndInstant()
String	getHistoryTable()
static String	getHistoryTable(String sessionId)
String	getMappingTable()
static String	getMappingTable(String sessionId)
static StarlakeSession	getPersistingSession(StarlakeConnection conn, String id, Map<String,String> options)
ai.starlake.transpiler.schema.CaseInsensitiveLinkedHashMap<net.sf.jsqlparser.schema.Table>	getReplacementTables()
String	getSessionId()
Instant	getStartInstant()
TreeMap<Instant,String>	getStatements()
StarlakeSession.Status	getStatus()
boolean	isFalse(String key)
static boolean	isFalse(Map<String,String> options, String key)
boolean	isPersistent()
boolean	isTrue(String key)
static boolean	isTrue(Map<String,String> options, String key)
String	rewriteSql(net.sf.jsqlparser.statement.Statement st, String sqlStr)
StarlakeSession	setEndInstant(Instant endInstant)
StarlakeSession	setStatus(StarlakeSession.Status status)

Methods inherited from class java.lang.Object

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

Field Details

BASE62

public static final String BASE62

See Also:

• Constant Field Values

LOGGER

public static final Logger LOGGER

dbObjects

public final ai.starlake.jdbc.DBObjects dbObjects

Constructor Details

StarlakeSession

public StarlakeSession(StarlakeConnection conn,
 String id,
 Map<String,String> options)
                throws SQLException

Throws:

SQLException

StarlakeSession

public StarlakeSession(StarlakeConnection conn,
 Map<String,String> options)
                throws SQLException

Throws:

SQLException

Method Details

connectionProperties

public static Map<String,String> connectionProperties(String jdbcUrl)

Extracts the values of "db" and "schema" from a JDBC URL. Both values are optional and may be null.

Parameters:

jdbcUrl - The JDBC connection URL.

Returns:

A map with keys "db" and "schema", values may be null if not present.

isPersistent

public boolean isPersistent()

isTrue

public boolean isTrue(String key)

isTrue

public static boolean isTrue(Map<String,String> options,
 String key)

isFalse

public boolean isFalse(String key)

isFalse

public static boolean isFalse(Map<String,String> options,
 String key)

getMappingTable

public String getMappingTable()

getMappingTable

public static String getMappingTable(String sessionId)

getHistoryTable

public String getHistoryTable()

getHistoryTable

public static String getHistoryTable(String sessionId)

getPersistingSession

public static StarlakeSession getPersistingSession(StarlakeConnection conn,
 String id,
 Map<String,String> options)
                                            throws SQLException

Throws:

SQLException

generateUniqueID

public static String generateUniqueID()

drop

public void drop(Map<String,String> options)

apply

public void apply(Map<String,String> options)

rewriteSql

public String rewriteSql(net.sf.jsqlparser.statement.Statement st,
 String sqlStr)
                  throws SQLException

Throws:

SQLException

getSessionId

public String getSessionId()

getStatus

public StarlakeSession.Status getStatus()

setStatus

public StarlakeSession setStatus(StarlakeSession.Status status)

getStartInstant

public Instant getStartInstant()

getEndInstant

public Instant getEndInstant()

setEndInstant

public StarlakeSession setEndInstant(Instant endInstant)

getReplacementTables

public ai.starlake.transpiler.schema.CaseInsensitiveLinkedHashMap<net.sf.jsqlparser.schema.Table> getReplacementTables()

getStatements

public TreeMap<Instant,String> getStatements()