Package com.killcoding.jsplus

Class ScriptConsole

java.lang.Object

com.killcoding.jsplus.ScriptConsole

All Implemented Interfaces:

ConsoleImpl

Direct Known Subclasses:

CmdConsole, JdbcConsole

public class ScriptConsole
extends Object
implements ConsoleImpl

Field Summary

Fields

Modifier and Type	Field	Description
protected static ConfigProperties	appenvCp
private CacheDriverExecutor	cacheDriverExecutor
protected Runnable	callback
protected Runnable	callbackBatch
protected CmdConsole	cmdConsole
protected static final Map<Integer,ScriptConsole>	CONNECT_CONSOLES
protected ConfigProperties	consoleVariables
private static DriverDataSource	datasource
protected ConfigProperties	datasourceVariables
protected String	displayEngineName
private String	engineName
private static ExecutorService	exitExecute
private static final List<Runnable>	exitRuns
private boolean	exportedCompleted
protected boolean	firstOpen
protected CacheArray	globalCacheArray
private String	intoValue
static final String	JS_PLUS_PATH_KEY
protected JsPlusContext	jsPlusContext
private String	lastSelectCommand
protected Logger	log
private long	preExecuteTime
private static final long	startedTimeMs
protected boolean	taskExecuted
private static Path	tmpPath
private boolean	useCmdEnv
private boolean	useJdbcEnv
private boolean	useScriptEnv

Fields inherited from interface com.killcoding.jsplus.ConsoleImpl

CALL_REGEX, CONSOLE_FUN_REGEX, CONSOLE_VAR_REGEX, DEFAULT_AutoCommit, DEFAULT_BatchSize, DEFAULT_CallStoredProcedureFun, DEFAULT_ColumnCut, DEFAULT_ColumnWidth, DEFAULT_CommandCancel, DEFAULT_CommandEnd, DEFAULT_CommandHistory, DEFAULT_Config_Cipher_AesKey, DEFAULT_DateFormat, DEFAULT_DateTimeFormat, DEFAULT_ExportCursorStart, DEFAULT_ExportMaxFileSize, DEFAULT_ExportMaxRows, DEFAULT_ExportOrderBy, DEFAULT_ExportSplit, DEFAULT_ExportTimer, DEFAULT_ExportUpperOrLowerCase, DEFAULT_ImportSplit, DEFAULT_Jdbc_Cipher_AesKey, DEFAULT_Name, DEFAULT_QueryCursorStart, DEFAULT_QueryMaxRows, DEFAULT_Quote, DEFAULT_Script_Cipher_AesKey, DEFAULT_ScriptEngine, DEFAULT_ShowResultBody, DEFAULT_ShowResultFooter, DEFAULT_ShowResultHeader, DEFAULT_ShowTaskLog, DEFAULT_Task, DEFAULT_TaskTimer, DEFAULT_TimeFormat, DEFAULT_WriteHistory, SELECT_REGEX, VERSION

Constructor Summary

Constructors

Constructor	Description
ScriptConsole()

Method Summary

Modifier and Type	Method	Description
void	abort()
private void	abort(Boolean enableSystemOut)
void	addExitRunnable(Runnable exitRun)
void	addHistory(String command)
Object	batch(List<String> params)
void	callback(Runnable callback)
void	callbackBatch(Runnable callbackBatch)
void	checkHistory()
void	clear()
private void	clear(Boolean enableSystemOut)
void	clearLastSelectCommand()
Object	clearLastSelectCommand(List<String> params)
void	close()
private void	close(Boolean enableSystemOut)
void	closeContext()
String	columnCut(String strValue)
void	commit()
private void	commit(Boolean enableSystemOut)
void	connect(int consoleHashCode)
Object	conver(String tableObjectFolder, String javaType, String encryptCell)
String	converToSqlFromMap(String schema, String tableName, List<String> columns)
protected CacheArrayFilter	createCacheArrayFilter(long filterTimer, long filterLoopTimer)
String	decryptScript(File scriptPath)
List<Map<String,Object>>	desc(String schema, String tableName)
Object	desc(List<String> params)
private static boolean	detectSystemExit()
static String	error(Exception e)
static String	escapeCsv(String input)
Object	eval(File scriptPath)
void	eval(Runnable execRun)
Object	eval(String scriptPath)
Object	evalScript(String script)
boolean	execute(String commands)
Object	executeBatch(String batchFile)
protected String	executeCmdBatch(String _batchFile)
protected String	executeJdbcBatch(String _batchFile)
boolean	executeViaCmd(boolean enableSystemOut, String commands)
boolean	executeViaCmd(boolean enableSystemOut, String commands, Runnable successfullyRun, Runnable faiiledRun)
boolean	executeViaCmd(Boolean enableSystemOut, String commands, Runnable successfullyRun, Runnable faiiledRun)
boolean	executeViaCmd(String commands)
boolean	executeViaJdbc(Boolean enableSystemOut, String commands)
boolean	executeViaJdbc(String commands)
boolean	executeViaScript(String commands)
static String	exit()
Object	exit(List<String> params)
String	exportTables(String schema, String exportToFolder)
Object	exportTables(List<String> params)
void	exportTo(File folder, String filePrefix)
void	exportTo(String file)
void	exportTo(String _lastSelectCommand, File folder, String filePrefix)
void	exportTo(String _lastSelectCommand, File folder, String filePrefix, Runnable completedRun, Runnable terminatedRun)
void	exportTo(String _lastSelectCommand, String file)
Object	exportTo(List<String> params)
String	exportUpperOrLowerCase(String s)
String	format(Object objValue)
String	formatCommand(String command)
String	formatForExport(Object objValue)
String	formatForExport(String tableObjectFolder, Object objValue)
String	formatObjectValue(boolean useEncrypt, boolean single, Object objValue, String tableObjectFolder)
String	genCreateTable(String schema, String tableName)
Object	genCreateTable(List<String> params)
String	genCreateTables(String schema, String sqlFilePath)
Object	genCreateTables(List<String> params)
static ConfigProperties	getAppenv()
CacheArrayFilter	getCacheArrayFilter(Boolean enableSystemOut)
CacheArrayFilter	getCacheArrayFilterForExport(boolean showTaskLog, String file)
CacheArrayFilter	getCacheArrayFilterForExport(boolean showTaskLog, String file, Runnable completedRun, Runnable terminatedRun)
CacheDriverExecutor	getCacheDriverExecutor()
CacheDriverExecutor	getCacheDriverExecutor(boolean refreshConnection)
CmdConsole	getCmdConsole()
protected ScriptConsole	getConsole()
Map<Integer,ScriptConsole>	getConsoles()
ConfigProperties	getConsoleVariables()
JsPlusContext	getContext()
DriverDataSource	getDataSource()
String	getDataType(boolean isId, String javaType, int precision)
protected String	getDisplayEngineName()
CacheArray	getGlobalCacheArray()
CacheArray	getGlobalCacheArray(long filterTimer, int filterLoopTimer)
String	getIntoValue()
static String	getJarPath()
static String	getJsPlusPath()
String	getLastSelectCommand()
String	help()
Object	help(List<String> params)
String	hostname()
Object	hostname(List<String> params)
String	importFrom(String schema, String tableName, String csv)
Object	importFrom(List<String> params)
String	importTables(String schema, String folder)
Object	importTables(List<String> params)
private void	initEnv()
void	initGlobalCacheArray(long filterTimer, long filterLoopTimer)
static void	initPool()
void	initScriptEngineManager()
void	initScriptEngineManager(boolean allowAllAccess)
void	into(String name)
Object	into(List<String> params)
boolean	isCommandCancel(String command)
boolean	isCommandEnd(String command)
boolean	isUseCmdEnv()
boolean	isUseJdbcEnv()
boolean	isUseScriptEnv()
void	loadAppenv()
double	memoryUsage()
double	memoryUsage(long using)
long	memoryUsing()
ScriptConsole	newBuilder()
ScriptConsole	newBuilder(boolean allowAllAccess)
ScriptConsole	newBuilder(String _engineName)
ScriptConsole	newBuilder(String _engineName, boolean allowAllAccess)
boolean	open()
private boolean	open(Boolean enableSystemOut)
static Map<String,Object>	parseArgs(String[] args)
String	quote(String tableOrColumn)
void	reset()
Object	reset(List<String> params)
void	rollback()
private void	rollback(Boolean enableSystemOut)
String	set(String key, Object value)
Object	set(List<String> params)
Boolean	setAutoCommit(Boolean autoCommit)
Object	setAutoCommit(List<String> params)
static void	setCacheApi(String apiClass)
Object	setCacheApi(List<String> params)
void	setConsoleVariables(ConfigProperties consoleVariables)
void	setDataSource(DriverDataSource datasource)
void	setIntoValue(Object value)
void	setLastSelectCommand(String lastSelectCommand)
static void	setStaticDataSource(DriverDataSource datasource)
void	setTask(String task)
void	setTask(String taskTimer, String task)
void	setUseCmdEnv()
void	setUseJdbcEnv()
void	setUseScriptEnv()
String	show(String key)
Object	show(List<String> params)
String	showAll()
Object	showAll(List<String> params)
Map<String,Object>	showColumnClasses(String tableName)
Object	showColumnClasses(List<String> params)
Map<String,Object>	showColumnTypes(String tableName)
Object	showColumnTypes(List<String> params)
void	showHistory(String hiscmd)
List<Map<String,Object>>	showTables()
List<Map<String,Object>>	showTables(String schema)
Object	showTables(List<String> params)
void	sleep(String sleepTime)
Object	sleep(List<String> params)
void	startTask(String taskTimer, String taskFile)
Object	startTask(List<String> params)
void	stopTask()
Object	stopTask(List<String> params)
protected void	task()
protected void	task(String task, Long taskTimer)
void	taskExecute()
byte[]	toByteArray(Blob blobValue)
byte[]	toByteArray(Clob clobValue)
String	toResultList(List<Map<String,Object>> list)
String	toSingle(String text)
static String	unescapeCsv(String input)
String	version()
Object	version(List<String> params)
Object	when(List<String> params)

Methods inherited from class java.lang.Object

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

Field Details

log

protected Logger log

CONNECT_CONSOLES

protected static final Map<Integer,ScriptConsole> CONNECT_CONSOLES

datasource

private static DriverDataSource datasource

datasourceVariables

protected ConfigProperties datasourceVariables

consoleVariables

protected ConfigProperties consoleVariables

appenvCp

protected static ConfigProperties appenvCp

taskExecuted

protected boolean taskExecuted

firstOpen

protected boolean firstOpen

useScriptEnv

private boolean useScriptEnv

useJdbcEnv

private boolean useJdbcEnv

useCmdEnv

private boolean useCmdEnv

engineName

private String engineName

preExecuteTime

private long preExecuteTime

cacheDriverExecutor

private CacheDriverExecutor cacheDriverExecutor

lastSelectCommand

private String lastSelectCommand

intoValue

private String intoValue

exportedCompleted

private boolean exportedCompleted

cmdConsole

protected CmdConsole cmdConsole

jsPlusContext

protected JsPlusContext jsPlusContext

displayEngineName

protected String displayEngineName

exitRuns

private static final List<Runnable> exitRuns

startedTimeMs

private static final long startedTimeMs

tmpPath

private static Path tmpPath

exitExecute

private static ExecutorService exitExecute

JS_PLUS_PATH_KEY

public static final String JS_PLUS_PATH_KEY

See Also:

• Constant Field Values

globalCacheArray

protected CacheArray globalCacheArray

callback

protected Runnable callback

callbackBatch

protected Runnable callbackBatch

Constructor Details

ScriptConsole

public ScriptConsole()

Method Details

getJsPlusPath

public static String getJsPlusPath()

initEnv

private void initEnv()

loadAppenv

public void loadAppenv()

getAppenv

public static ConfigProperties getAppenv()

detectSystemExit

private static boolean detectSystemExit()
                                 throws IOException

Throws:

IOException

initPool

public static void initPool()

setStaticDataSource

public static void setStaticDataSource(DriverDataSource datasource)

setDataSource

public void setDataSource(DriverDataSource datasource)

getDataSource

public DriverDataSource getDataSource()
                               throws IOException

Throws:

IOException

getIntoValue

public String getIntoValue()

getLastSelectCommand

public String getLastSelectCommand()

getCacheDriverExecutor

public CacheDriverExecutor getCacheDriverExecutor()

getCacheDriverExecutor

public CacheDriverExecutor getCacheDriverExecutor(boolean refreshConnection)

getConsoleVariables

public ConfigProperties getConsoleVariables()

setConsoleVariables

public void setConsoleVariables(ConfigProperties consoleVariables)

setLastSelectCommand

public void setLastSelectCommand(String lastSelectCommand)

clearLastSelectCommand

public void clearLastSelectCommand()

into

public void into(String name)

sleep

public void sleep(String sleepTime)
           throws Exception

Throws:

Exception

hostname

public String hostname()
                throws Exception

Throws:

Exception

startTask

public void startTask(String taskTimer,
 String taskFile)

stopTask

public void stopTask()

callback

public void callback(Runnable callback)
              throws Exception

Throws:

Exception

callbackBatch

public void callbackBatch(Runnable callbackBatch)
                   throws Exception

Throws:

Exception

getGlobalCacheArray

public CacheArray getGlobalCacheArray(long filterTimer,
 int filterLoopTimer)

getGlobalCacheArray

public CacheArray getGlobalCacheArray()

createCacheArrayFilter

protected CacheArrayFilter createCacheArrayFilter(long filterTimer,
 long filterLoopTimer)

initGlobalCacheArray

public void initGlobalCacheArray(long filterTimer,
 long filterLoopTimer)

initScriptEngineManager

public void initScriptEngineManager()
                             throws Exception

Throws:

Exception

initScriptEngineManager

public void initScriptEngineManager(boolean allowAllAccess)
                             throws Exception

Throws:

Exception

getContext

public JsPlusContext getContext()

eval

public Object eval(String scriptPath)
            throws Exception

Throws:

Exception

eval

public Object eval(File scriptPath)
            throws Exception

Throws:

Exception

eval

public void eval(Runnable execRun)
          throws Exception

Throws:

Exception

closeContext

public void closeContext()
                  throws Exception

Throws:

Exception

newBuilder

public ScriptConsole newBuilder(String _engineName,
 boolean allowAllAccess)
                         throws Exception

Throws:

Exception

newBuilder

public ScriptConsole newBuilder(String _engineName)
                         throws Exception

Throws:

Exception

newBuilder

public ScriptConsole newBuilder(boolean allowAllAccess)
                         throws Exception

Throws:

Exception

newBuilder

public ScriptConsole newBuilder()
                         throws Exception

Throws:

Exception

desc

public List<Map<String,Object>> desc(String schema,
 String tableName)
                              throws Exception

Throws:

Exception

showTables

public List<Map<String,Object>> showTables()
                                    throws Exception

Throws:

Exception

showTables

public List<Map<String,Object>> showTables(String schema)
                                    throws Exception

Throws:

Exception

showColumnTypes

public Map<String,Object> showColumnTypes(String tableName)
                                   throws Exception

Throws:

Exception

showColumnClasses

public Map<String,Object> showColumnClasses(String tableName)
                                     throws Exception

Throws:

Exception

set

public String set(String key,
 Object value)

show

public String show(String key)

showAll

public String showAll()

setAutoCommit

public Boolean setAutoCommit(Boolean autoCommit)
                      throws Exception

Throws:

Exception

genCreateTables

public String genCreateTables(String schema,
 String sqlFilePath)

genCreateTable

public String genCreateTable(String schema,
 String tableName)
                      throws Exception

Throws:

Exception

getDataType

public String getDataType(boolean isId,
 String javaType,
 int precision)

setCacheApi

public static void setCacheApi(String apiClass)
                        throws Exception

Throws:

Exception

reset

public void reset()

converToSqlFromMap

public String converToSqlFromMap(String schema,
 String tableName,
 List<String> columns)

conver

public Object conver(String tableObjectFolder,
 String javaType,
 String encryptCell)
              throws Exception

Throws:

Exception

getJarPath

public static String getJarPath()

exportTo

public void exportTo(String _lastSelectCommand,
 File folder,
 String filePrefix)
              throws Exception

Throws:

Exception

exportTo

public void exportTo(File folder,
 String filePrefix)
              throws Exception

Throws:

Exception

exportTo

public void exportTo(String _lastSelectCommand,
 String file)
              throws Exception

Throws:

Exception

exportTo

public void exportTo(String file)
              throws Exception

Throws:

Exception

getCacheArrayFilterForExport

public CacheArrayFilter getCacheArrayFilterForExport(boolean showTaskLog,
 String file)

exportTo

public void exportTo(String _lastSelectCommand,
 File folder,
 String filePrefix,
 Runnable completedRun,
 Runnable terminatedRun)
              throws Exception

Throws:

Exception

getCacheArrayFilterForExport

public CacheArrayFilter getCacheArrayFilterForExport(boolean showTaskLog,
 String file,
 Runnable completedRun,
 Runnable terminatedRun)

format

public String format(Object objValue)

formatForExport

public String formatForExport(Object objValue)

formatForExport

public String formatForExport(String tableObjectFolder,
 Object objValue)

formatObjectValue

public String formatObjectValue(boolean useEncrypt,
 boolean single,
 Object objValue,
 String tableObjectFolder)

toByteArray

public byte[] toByteArray(Blob blobValue)

toByteArray

public byte[] toByteArray(Clob clobValue)

columnCut

public String columnCut(String strValue)

toSingle

public String toSingle(String text)

clear

public void clear()

clear

private void clear(Boolean enableSystemOut)

open

public boolean open()

close

public void close()

commit

public void commit()

rollback

public void rollback()

abort

public void abort()

abort

private void abort(Boolean enableSystemOut)
            throws SQLException

Throws:

SQLException

rollback

private void rollback(Boolean enableSystemOut)
               throws SQLException

Throws:

SQLException

commit

private void commit(Boolean enableSystemOut)
             throws SQLException

Throws:

SQLException

close

private void close(Boolean enableSystemOut)
            throws SQLException

Throws:

SQLException

open

private boolean open(Boolean enableSystemOut)

executeBatch

public Object executeBatch(String batchFile)
                    throws Exception

Throws:

Exception

executeCmdBatch

protected String executeCmdBatch(String _batchFile)
                          throws Exception

Throws:

Exception

executeJdbcBatch

protected String executeJdbcBatch(String _batchFile)
                           throws Exception

Throws:

Exception

evalScript

public Object evalScript(String script)
                  throws Exception

Throws:

Exception

executeViaCmd

public boolean executeViaCmd(boolean enableSystemOut,
 String commands)

executeViaCmd

public boolean executeViaCmd(boolean enableSystemOut,
 String commands,
 Runnable successfullyRun,
 Runnable faiiledRun)

executeViaScript

public boolean executeViaScript(String commands)

execute

public boolean execute(String commands)

executeViaJdbc

public boolean executeViaJdbc(String commands)

executeViaCmd

public boolean executeViaCmd(String commands)

executeViaCmd

public boolean executeViaCmd(Boolean enableSystemOut,
 String commands,
 Runnable successfullyRun,
 Runnable faiiledRun)

executeViaJdbc

public boolean executeViaJdbc(Boolean enableSystemOut,
 String commands)

getCacheArrayFilter

public CacheArrayFilter getCacheArrayFilter(Boolean enableSystemOut)

checkHistory

public void checkHistory()

addHistory

public void addHistory(String command)

showHistory

public void showHistory(String hiscmd)

toResultList

public String toResultList(List<Map<String,Object>> list)

isCommandEnd

public boolean isCommandEnd(String command)

isCommandCancel

public boolean isCommandCancel(String command)

parseArgs

public static Map<String,Object> parseArgs(String[] args)

task

protected void task()
             throws Exception

Throws:

Exception

task

protected void task(String task,
 Long taskTimer)
             throws Exception

Throws:

Exception

setTask

public void setTask(String taskTimer,
 String task)

setTask

public void setTask(String task)

taskExecute

public void taskExecute()

importFrom

public String importFrom(String schema,
 String tableName,
 String csv)
                  throws Exception

Throws:

Exception

importTables

public String importTables(String schema,
 String folder)

exportTables

public String exportTables(String schema,
 String exportToFolder)

quote

public String quote(String tableOrColumn)

setIntoValue

public void setIntoValue(Object value)

formatCommand

public String formatCommand(String command)

exportUpperOrLowerCase

public String exportUpperOrLowerCase(String s)

getCmdConsole

public CmdConsole getCmdConsole()

error

public static String error(Exception e)

exit

public static String exit()

memoryUsing

public long memoryUsing()

memoryUsage

public double memoryUsage(long using)

memoryUsage

public double memoryUsage()

addExitRunnable

public void addExitRunnable(Runnable exitRun)

version

public String version()

setUseJdbcEnv

public void setUseJdbcEnv()

setUseScriptEnv

public void setUseScriptEnv()

setUseCmdEnv

public void setUseCmdEnv()

isUseJdbcEnv

public boolean isUseJdbcEnv()

isUseScriptEnv

public boolean isUseScriptEnv()

isUseCmdEnv

public boolean isUseCmdEnv()

help

public String help()

connect

public void connect(int consoleHashCode)

getConsole

protected ScriptConsole getConsole()

getDisplayEngineName

protected String getDisplayEngineName()

getConsoles

public Map<Integer,ScriptConsole> getConsoles()

decryptScript

public String decryptScript(File scriptPath)
                     throws Exception

Throws:

Exception

version

public Object version(List<String> params)

help

public Object help(List<String> params)

exit

public Object exit(List<String> params)

reset

public Object reset(List<String> params)

setCacheApi

public Object setCacheApi(List<String> params)

when

public Object when(List<String> params)

into

public Object into(List<String> params)

batch

public Object batch(List<String> params)

sleep

public Object sleep(List<String> params)

hostname

public Object hostname(List<String> params)

startTask

public Object startTask(List<String> params)

stopTask

public Object stopTask(List<String> params)

set

public Object set(List<String> params)

show

public Object show(List<String> params)

showAll

public Object showAll(List<String> params)

importTables

public Object importTables(List<String> params)

clearLastSelectCommand

public Object clearLastSelectCommand(List<String> params)

exportTables

public Object exportTables(List<String> params)

desc

public Object desc(List<String> params)

showTables

public Object showTables(List<String> params)

showColumnTypes

public Object showColumnTypes(List<String> params)

showColumnClasses

public Object showColumnClasses(List<String> params)

exportTo

public Object exportTo(List<String> params)

importFrom

public Object importFrom(List<String> params)

setAutoCommit

public Object setAutoCommit(List<String> params)

genCreateTables

public Object genCreateTables(List<String> params)

genCreateTable

public Object genCreateTable(List<String> params)

escapeCsv

public static String escapeCsv(String input)

unescapeCsv

public static String unescapeCsv(String input)