opensource/HeidiSQL
1
0
Fork 0
mirror of https://github.com/HeidiSQL/HeidiSQL.git synced 2026-03-13 09:24:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

make oracle and mysql specific

Browse Source
This commit is contained in:
servertood
2008-12-29 20:35:33 +00:00
parent d0e0b78f1c
commit 43bede85f0
4 changed files with 247 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

121
extra/jheidi/loadTableDataMySQLWorker.ajl Normal file
View File

@@ -0,0 +1,121 @@
import java.util.*;
String event = arg("workerEvent");
if ( event == "init" || event == "done")
{
return;
}
WindowContext context = argObj("windowContext");
Text banner = context.get("/mainTabs/Data/toolbar/banner");
Panel tab = context.get("/mainTabs/Data");
Worker worker = argObj("worker");
Table table = context.get("/mainTabs/Data/table");
Toolbar tb = context.get("/mainTabs/Data/toolbar");
final String tableName = arg("tableName");
final String dbName = arg("dbName");
boolean setRefresh = false;
if ( event == "longRunningTask" || event == "alreadyRunning")
{
if ( worker.isDone() && event=="longRunningTask" )
return;
if ( tableName.equals((String)context.get("currentTable")) &&
dbName.equals((String)context.get("currentDB")))
{
banner.setText(dbName + "." + tableName + " (loading)");
table.clear();
tb.updateUI();
}
}
else if ( event == "cancelled" )
{
DB db = worker.getProperty("db");
if ( db != null )
db.cancel();
if ( tableName.equals((String)context.get("currentTable")) &&
dbName.equals((String)context.get("currentDB")))
{
banner.setText(dbName + "." + tableName + " (load canceled)");
setRefresh = true;
}
}
else if ( event == "backgroundTask" )
{
final DB db = new SQLLoggingDB((SQLLoggingDB)context.get("db"));
worker.setProperty("db", db);
worker.setProperty("waitOperation", "select count(*) from " + dbName + "." + tableName +"; select * from " + dbName + "." + tableName);
DB.AutoCleanupTX tx = new DB.AutoCleanupTX() {
public void execute() {
DB.Result count = db.execute("select count(*) from `" + dbName + "`.`" + tableName + "`");
DB.Result data = db.execute("select * from `" + dbName + "`.`" + tableName + "` limit 50");
HashObject ho = new HashObject();
ho.put("count", count);
ho.put("data", data);
/*try
{
Thread.sleep(5000);
} catch (Exception e) {}*/
publish(ho);
}
};
db.execute(tx);
}
else if ( event == "update")
{
HashObject resultSets = (HashObject)((java.util.List)argObj("taskResult")).get(0);
DB.Result data = resultSets.getObject("data");
DB.Result count = resultSets.getObject("count");
if ( tableName.equals((String)context.get("currentTable")) &&
dbName.equals((String)context.get("currentDB")))
{
banner.setText(dbName + "." + tableName + ": " + count.first().get(0) + " total rows");
TableUtils.populate(table, data);
setRefresh = true;
}
}
if ( setRefresh )
{
tab.setProperty("refreshScript", "loadTableDataMySQLWorker");
tab.setProperty("refreshArgs", args());
}

121
extra/jheidi/loadTableDataOracleWorker.ajl Normal file
View File

@@ -0,0 +1,121 @@
import java.util.*;
String event = arg("workerEvent");
if ( event == "init" || event == "done")
{
return;
}
WindowContext context = argObj("windowContext");
Text banner = context.get("/mainTabs/Data/toolbar/banner");
Panel tab = context.get("/mainTabs/Data");
Worker worker = argObj("worker");
Table table = context.get("/mainTabs/Data/table");
Toolbar tb = context.get("/mainTabs/Data/toolbar");
final String tableName = arg("tableName");
final String dbName = arg("dbName");
boolean setRefresh = false;
if ( event == "longRunningTask" || event == "alreadyRunning")
{
if ( worker.isDone() && event=="longRunningTask" )
return;
if ( tableName.equals((String)context.get("currentTable")) &&
dbName.equals((String)context.get("currentDB")))
{
banner.setText(dbName + "." + tableName + " (loading)");
table.clear();
tb.updateUI();
}
}
else if ( event == "cancelled" )
{
DB db = worker.getProperty("db");
if ( db != null )
db.cancel();
if ( tableName.equals((String)context.get("currentTable")) &&
dbName.equals((String)context.get("currentDB")))
{
banner.setText(dbName + "." + tableName + " (load canceled)");
setRefresh = true;
}
}
else if ( event == "backgroundTask" )
{
final DB db = new SQLLoggingDB((SQLLoggingDB)context.get("db"));
worker.setProperty("db", db);
worker.setProperty("waitOperation", "select count(*) from " + dbName + "." + tableName +"; select * from " + dbName + "." + tableName);
DB.AutoCleanupTX tx = new DB.AutoCleanupTX() {
public void execute() {
DB.Result count = db.execute("select count(*) from " + dbName + "." + tableName);
DB.Result data = db.execute("select * from " + dbName + "." + tableName + " where rownum < 50");
HashObject ho = new HashObject();
ho.put("count", count);
ho.put("data", data);
/*try
{
Thread.sleep(5000);
} catch (Exception e) {}*/
publish(ho);
}
};
db.execute(tx);
}
else if ( event == "update")
{
HashObject resultSets = (HashObject)((java.util.List)argObj("taskResult")).get(0);
DB.Result data = resultSets.getObject("data");
DB.Result count = resultSets.getObject("count");
if ( tableName.equals((String)context.get("currentTable")) &&
dbName.equals((String)context.get("currentDB")))
{
banner.setText(dbName + "." + tableName + ": " + count.first().get(0) + " total rows");
TableUtils.populate(table, data);
setRefresh = true;
}
}
if ( setRefresh )
{
tab.setProperty("refreshScript", "loadTableDataOracleWorker");
tab.setProperty("refreshArgs", args());
}

6
extra/jheidi/schemaTreeEventsMySQL.ajl
View File

@@ -99,11 +99,11 @@
Thread.sleep(25);
} catch (Exception e) {}
args().put("workerKey", "loadTableData" + dbName + tableName);
w = worker("loadTableDataWorker", args(), Worker.RunOption.LET_FINISH_IF_RUNNING);
args().put("workerKey", "loadTableDataMySQLWorker" + dbName + tableName);
w = worker("loadTableDataMySQLWorker", args(), Worker.RunOption.LET_FINISH_IF_RUNNING);
if ( !w.isCancelled() )
LongRunningTask.detect("loadTableData" + dbName+tableName, "progressWaiter", args(), w , 250);
LongRunningTask.detect("loadTableDataMySQLWorker" + dbName+tableName, "progressWaiter", args(), w , 250);
}

4
extra/jheidi/schemaTreeEventsOracle.ajl
View File

@@ -99,11 +99,11 @@
Thread.sleep(25);
} catch (Exception e) {}
args().put("workerKey", "loadTableDataOracle" + dbName + tableName);
args().put("workerKey", "loadTableDataOracleWorker" + dbName + tableName);
w = worker("loadTableDataOracleWorker", args(), Worker.RunOption.LET_FINISH_IF_RUNNING);
if ( !w.isCancelled() )
LongRunningTask.detect("loadTableDataOracle" + dbName+tableName, "progressWaiter", args(), w , 250);
LongRunningTask.detect("loadTableDataOracleWorker" + dbName+tableName, "progressWaiter", args(), w , 250);
}