import com.quantum.adapters.DatabaseAdapter;
import com.quantum.model.Bookmark;
import com.quantum.model.Column;
-import com.quantum.model.ConnectionException;
import com.quantum.model.Entity;
import com.quantum.model.NotConnectedException;
-import com.quantum.sql.TableRow;
-import com.quantum.view.ViewHelper;
-import com.quantum.view.tableview.TableAdapter;
+import com.quantum.sql.MultiSQLServer;
+import com.quantum.sql.SQLResultSetResults;
+import com.quantum.sql.SQLResults;
+import com.quantum.ui.dialog.SQLExceptionDialog;
+import com.quantum.util.connection.ConnectionUtil;
import org.eclipse.jface.wizard.WizardPage;
/**
- * @author BC
+ * @author BC Holmes
*/
public abstract class BaseSQLPage extends WizardPage implements SQLPage {
- protected TableRow row;
- protected TableAdapter adapter;
+ protected SQLResultSetResults.Row row;
+ protected SQLResultSetResults results;
+ private ConnectionUtil connectionUtil = new ConnectionUtil();
public BaseSQLPage(String pageName) {
super(pageName);
}
public boolean performFinish() {
- try {
- Bookmark bookmark = this.adapter.getBookmark();
- bookmark.addQuery(getQueryText());
- ViewHelper.tryGetResults(getShell(), bookmark.getConnection(), getQueryText());
- } catch (ConnectionException e) {
- e.printStackTrace();
- }
- return true;
- }
+ Bookmark bookmark = this.results.getBookmark();
+ try {
+ bookmark.addQuery(getQueryText());
+ SQLResults sqlResults = MultiSQLServer.getInstance().execute(bookmark,
+ this.connectionUtil.getConnection(bookmark, getShell()), getQueryText());
+ return sqlResults == null ? false : true;
+ } catch (SQLException e) {
+ SQLExceptionDialog.openException(getShell(), bookmark, e);
+ return false;
+ }
+ }
+
protected abstract String getQueryText();
protected void appendColumn(StringBuffer whereClause, Entity entity, String columnName, DatabaseAdapter adapter, String value) {
return null;
}
}
- public void init(TableRow row, TableAdapter adapter) {
- this.row = row;
- this.adapter = adapter;
+ public void init(SQLResultSetResults results, SQLResultSetResults.Row row) {
+ this.results = results;
+ this.row = row;
}
}