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 data tab loader a worker

Browse Source
This commit is contained in:
servertood
2008-11-23 06:43:34 +00:00
parent ed3843a542
commit dd32a9f7a4
3 changed files with 127 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
extra/jheidi/loadTableData.ajl
View File

@@ -1,43 +0,0 @@
WindowContext context = argObj("windowContext");
DB db = context.get("db");
Table table = context.get("/mainTabs/Data/table");
db.begin();
db.execute("use `" + arg("dbName") + "`");
DB.Result count = db.query("select count(*) from `" + arg("tableName") + "`");
DB.Result data = db.query("select * from `" + arg("tableName") + "` limit 50");
db.end();
Text banner = context.get("/mainTabs/Data/toolbar/banner");
banner.setText(arg("dbName") + "." + arg("tableName") + ": " + count.first().get(0) + " total rows");
TableUtils.populate(table, data);
//let the refresh button know what to do
Panel tab = context.get("/mainTabs/Data");
tab.setProperty("refreshScript", "loadTableData");
tab.setProperty("refreshArgs", args());

121
extra/jheidi/loadTableDataWorker.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", "loadTableDataWorker");
tab.setProperty("refreshArgs", args());
}

9
extra/jheidi/schemaTreeEvents.ajl
View File

@@ -58,7 +58,6 @@
args().put("selectedTab", "Database");
thread("resetTabs", args(), true);
args().put("dbName", dbName);
args().put("waitOperation", "show table status from `" + dbName + "`");
args().put("workerKey", dbName);
Worker w = worker("showTableStatusWorker", args(), Worker.RunOption.LET_FINISH_IF_RUNNING);
@@ -76,7 +75,6 @@
args().put("dbName", dbName);
args().put("tableName", tableName);
args().put("waitOperation", "show full columns from `" + dbName + "`.`" + tableName + "`");
args().put("workerKey", dbName+tableName);
Worker w = worker("loadTableInfoWorker", args(), Worker.RunOption.LET_FINISH_IF_RUNNING);
@@ -84,7 +82,12 @@
if ( !w.isCancelled() )
LongRunningTask.detect(dbName+tableName, "progressWaiter", args(), w , 250);
thread("loadTableData", args(), true);
args().put("workerKey", "loadTableData" + dbName + tableName);
w = worker("loadTableDataWorker", args(), Worker.RunOption.LET_FINISH_IF_RUNNING);
if ( !w.isCancelled() )
LongRunningTask.detect("loadTableData" + dbName+tableName, "progressWaiter", args(), w , 250);
}