开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
ReverseEngineeringSybase.java
资源名称：mysql-gui-tools-noinstall-5.0-r17-win32.zip　[点击查看]
上传用户：cccombo
上传日期：2021-01-31
资源大小：16445k
文件大小：23k
源码类别：

MySQL数据库

开发平台：

SQL

ReverseEngineeringSybase.java：源码内容
  1. package com.mysql.grt.modules;
  3. import java.sql.*;
  5. import com.mysql.grt.*;
  6. import com.mysql.grt.db.sybase.*;
  8. /**
  9.  * GRT Reverse Engineering Class for Sybase
  10.  * 
  11.  * @author MikeZ
  12.  * @version 1.0, 06/23/06
  13.  * 
  14.  */
  15. public class ReverseEngineeringSybase extends ReverseEngineeringGeneric {
  17. /**
  18.  * Static function to return information about this class to the GRT
  19.  * environment
  20.  * 
  21.  * @return returns a GRT XML string containing the infos about this class
  22.  */
  23. public static String getModuleInfo() {
  24. return Grt.getModuleInfoXml(ReverseEngineeringSybase.class,
  25. "ReverseEngineering");
  26. }
  28. private static String catalogsSelect = "SELECT name FROM master.dbo.sysdatabases "
  29. + "ORDER BY 1";
  31. /**
  32.  * Returns a list of all catalogs from the given JDBC connection
  33.  * 
  34.  * @param dbConn
  35.  *            the connection to use
  36.  * 
  37.  * @return returns a GRT XML string containing a list of schemata names
  38.  */
  39. public static GrtStringList getCatalogs(
  40. com.mysql.grt.db.mgmt.Connection dbConn) throws Exception {
  41. GrtStringList catalogList = new GrtStringList();
  43. GrtStringHashMap paramValues = dbConn.getParameterValues();
  44. paramValues.add("database", "");
  46. // connect to the database
  47. Connection conn = establishConnection(dbConn);
  48. try {
  50. Grt.getInstance().addMsg("Fetching catalog list.");
  51. Grt.getInstance().addMsgDetail(catalogsSelect);
  52. Grt.getInstance().flushMessages();
  54. PreparedStatement stmt = conn.prepareStatement(catalogsSelect);
  55. try {
  56. ResultSet rset = stmt.executeQuery();
  57. while (rset.next()) {
  58. catalogList.add(rset.getString(1));
  59. }
  60. } finally {
  61. stmt.close();
  62. }
  63. } finally {
  64. conn.close();
  65. }
  67. return catalogList;
  68. }
  70. private static String schemataSelect = "SELECT USERNAME = name "
  71. + "FROM sysusers WHERE gid != uid ORDER BY 1";
  73. /**
  74.  * Returns a list of all schemata from the given JDBC connection
  75.  * 
  76.  * @param dbConn
  77.  *            the connection to use
  78.  * 
  79.  * @return returns a GRT XML string containing a list of schemata names
  80.  */
  81. public static GrtStringList getSchemata(
  82. com.mysql.grt.db.mgmt.Connection dbConn) throws Exception {
  84. GrtStringList schemataList = new GrtStringList();
  86. // connect to the database
  87. Connection conn = establishConnection(dbConn);
  88. try {
  89. String catalog = dbConn.getParameterValues().get("database");
  91. Grt.getInstance().addMsg("Fetching schemata list.");
  92. Grt.getInstance().addMsgDetail(schemataSelect);
  93. Grt.getInstance().flushMessages();
  95. Statement stmt = conn.createStatement();
  96. try {
  97. ResultSet rset = stmt.executeQuery(schemataSelect);
  98. while (rset.next()) {
  99. schemataList.add(catalog + "." + rset.getString(1));
  100. }
  101. } finally {
  102. stmt.close();
  103. }
  104. } finally {
  105. conn.close();
  106. }
  108. Grt.getInstance().addMsg("Return schemata list.");
  109. Grt.getInstance().flushMessages();
  111. return schemataList;
  112. }
  114. /**
  115.  * Does the reverse engineering of the given schematas over the JDBC
  116.  * connection and returns the GRT objects
  117.  * 
  118.  * @param jdbcDriver
  119.  *            the class name of the JDBC driver
  120.  * @param jdbcConnectionString
  121.  *            a JDBC connection string
  122.  * @param schemataList
  123.  *            list of schematas to be reverse engineered
  124.  * @return returns a GRT XML string containing a the reverse engineered
  125.  *         objects
  126.  */
  127. public static com.mysql.grt.db.Catalog reverseEngineer(
  128. com.mysql.grt.db.mgmt.Connection dbConn, GrtStringList schemataList)
  129. throws Exception {
  131. boolean reverseEngineerOnlyTableObjects = (Grt.getInstance()
  132. .getGrtGlobalAsInt(
  133. "/migration/applicationData/"
  134. + "reverseEngineerOnlyTableObjects") == 1);
  136. // connect to the database
  137. Connection conn = establishConnection(dbConn);
  139. // create reveng instance
  140. ReverseEngineeringSybase revEng = new ReverseEngineeringSybase();
  142. Catalog catalog = new Catalog(null);
  143. catalog.setName(dbConn.getParameterValues().get("database"));
  145. catalog.setVersion(getVersion(dbConn));
  147. Grt.getInstance().addMsg("Build simple Sybase datatypes.");
  148. Grt.getInstance().flushMessages();
  149. revEng.buildSimpleDatatypes(dbConn, catalog);
  151. for (int i = 0; i < schemataList.size(); i++) {
  152. String schemaName = schemataList.get(i);
  153. schemaName = schemaName.substring(catalog.getName().length() + 1);
  155. Schema schema = new Schema(catalog);
  156. schema.setName(schemaName);
  157. catalog.getSchemata().add(schema);
  159. // Get Tables
  160. if (revEng.reverseEngineerTables(conn, catalog, schema) == 0
  161. && !reverseEngineerOnlyTableObjects) {
  163. // Get Views
  164. revEng.reverseEngineerViews(conn, catalog, schema);
  166. // Get SPs
  167. revEng.reverseEngineerProcedures(conn, catalog, schema);
  168. }
  169. }
  171. // make sure the Fks use real references instead of
  172. // text names where possible
  173. revEng.reverseEngineerUpdateFkReferences(catalog);
  175. return catalog;
  176. }
  178. protected void buildSimpleDatatypes(
  179. com.mysql.grt.db.mgmt.Connection dbConn, Catalog catalog) {
  180. com.mysql.grt.db.mgmt.Driver driver = dbConn.getDriver();
  181. com.mysql.grt.db.mgmt.Rdbms rdbms = (com.mysql.grt.db.mgmt.Rdbms) driver
  182. .getOwner();
  183. com.mysql.grt.db.SimpleDatatypeList rdbmsDatatypeList = rdbms
  184. .getSimpleDatatypes();
  185. com.mysql.grt.db.SimpleDatatypeList schemaDatatypeList = new com.mysql.grt.db.SimpleDatatypeList();
  187. for (int i = 0; i < rdbmsDatatypeList.size(); i++) {
  188. schemaDatatypeList.add(rdbmsDatatypeList.get(i));
  189. }
  191. catalog.setSimpleDatatypes(schemaDatatypeList);
  192. }
  194. private static String tableCountSelect = "SELECT TABLE_COUNT = COUNT(*) "
  195. + "FROM sysobjects O, sysindexes I "
  196. + "WHERE USER_NAME(uid) = ? AND O.type = 'U' AND O.id = I.id AND I.indid IN (0, 1)";
  198. private static String tableSelect = "SELECT TABLE_NAME = O.name "
  199. + "FROM sysobjects O, sysindexes I "
  200. + "WHERE USER_NAME(uid) = ? AND O.type = 'U' AND O.id = I.id AND I.indid IN (0, 1) "
  201. + "ORDER BY 1";
  203. protected int reverseEngineerTables(Connection conn, Catalog catalog,
  204. Schema schema) throws Exception {
  206. int tableCount = 0;
  207. int currentTableNumber = 0;
  209. Grt.getInstance().addMsg(
  210. "Fetch the number of tables in the schema " + schema.getName()
  211. + ".");
  212. Grt.getInstance().addMsgDetail(tableCountSelect);
  214. PreparedStatement stmt = conn.prepareStatement(tableCountSelect);
  215. stmt.setString(1, schema.getName());
  217. ResultSet tblRset = stmt.executeQuery();
  218. if (tblRset.next()) {
  219. tableCount = tblRset.getInt(1);
  220. }
  221. stmt.close();
  223. Grt.getInstance().addMsg(
  224. "Fetching " + tableCount + " table(s) of the schema "
  225. + schema.getName() + ".");
  226. Grt.getInstance().addMsgDetail(tableSelect);
  227. Grt.getInstance().flushMessages();
  229. stmt = conn.prepareStatement(tableSelect);
  230. stmt.setString(1, schema.getName());
  232. tblRset = stmt.executeQuery();
  234. while (tblRset.next()) {
  235. // Create new table
  236. Table table = new Table(schema);
  237. schema.getTables().add(table);
  239. currentTableNumber++;
  241. table.setName(tblRset.getString("TABLE_NAME"));
  243. Grt.getInstance().addProgress(
  244. "Processing table " + table.getName() + ".",
  245. (currentTableNumber * 100) / tableCount);
  246. if (Grt.getInstance().flushMessages() != 0) {
  247. Grt.getInstance().addMsg("Migration canceled by user.");
  248. return 1;
  249. }
  251. reverseEngineerTableColumns(conn, catalog, schema, table);
  253. reverseEngineerTablePK(conn, catalog, schema, table);
  255. reverseEngineerTableIndices(conn, catalog, schema, table);
  257. reverseEngineerTableFKs(conn, catalog, schema, table);
  259. }
  261. Grt.getInstance().addProgress("", -1);
  262. Grt.getInstance().flushMessages();
  264. stmt.close();
  266. return 0;
  267. }
  269. private static String tableColumnSelect = "SELECT COLUMN_NAME = ISNULL(C.name, ''), "
  270. + " DATA_TYPE = T.name, C.length, NUMERIC_PRECISION = C.prec, "
  271. + " NUMERIC_SCALE = C.scale, "
  272. + " IS_NULLABLE = CONVERT(BIT, (C.status & 0x08)) "
  273. + "FROM syscolumns C, systypes T, sysobjects A "
  274. + "WHERE USER_NAME(A.uid) = ? AND "
  275. + " A.id = C.id AND C.id = OBJECT_ID(?) AND "
  276. + "C.usertype*=T.usertype " + "ORDER BY C.colid";
  278. protected void reverseEngineerTableColumns(Connection conn,
  279. Catalog catalog, Schema schema, Table table) {
  281. try {
  282. Grt.getInstance().addMsg("Fetching column information.");
  283. Grt.getInstance().addMsgDetail(tableColumnSelect);
  285. PreparedStatement stmt = conn.prepareStatement(tableColumnSelect);
  286. stmt.setString(1, schema.getName());
  287. stmt.setString(2, table.getName());
  289. ResultSet colRset = stmt.executeQuery();
  290. while (colRset.next()) {
  291. // create new column
  292. Column column = new Column(table);
  293. table.getColumns().add(column);
  295. column.setName(colRset.getString("COLUMN_NAME"));
  296. column.setDatatypeName(colRset.getString("DATA_TYPE"));
  298. // Get Simple Type
  299. int datatypeIndex = catalog.getSimpleDatatypes()
  300. .getIndexOfName(column.getDatatypeName().toUpperCase());
  302. if (datatypeIndex > -1) {
  303. column.setSimpleType(catalog.getSimpleDatatypes().get(
  304. datatypeIndex));
  305. } else {
  306. column.setSimpleType(catalog.getSimpleDatatypes().get(
  307. catalog.getSimpleDatatypes().getIndexOfName(
  308. "VARCHAR")));
  309. column.setLength(255);
  311. Grt.getInstance().addMsg(
  312. "WARNING: The datatype " + column.getDatatypeName()
  313. + " was not been defined yet.");
  314. }
  316. column.setLength(colRset.getInt("LENGTH"));
  317. column.setPrecision(colRset.getInt("NUMERIC_PRECISION"));
  318. column.setScale(colRset.getInt("NUMERIC_SCALE"));
  320. // Nullable
  321. if (colRset.getString("IS_NULLABLE").compareToIgnoreCase("1") == 0) {
  322. column.setIsNullable(1);
  323. } else {
  324. column.setIsNullable(0);
  325. }
  326. }
  328. stmt.close();
  329. } catch (Exception e) {
  330. Grt.getInstance().addErr(e.getMessage());
  331. }
  332. }
  334. private static String tablePKSP = "sp_pkeys @table_owner=?, @table_name=?";
  336. protected void reverseEngineerTablePK(Connection conn, Catalog catalog,
  337. Schema schema, Table table) {
  339. // String sql;
  341. try {
  342. Grt.getInstance().addMsg("Fetching primary key information.");
  343. Grt.getInstance().addMsgDetail(tablePKSP);
  345. PreparedStatement stmt = conn.prepareCall(tablePKSP);
  346. stmt.setString(1, schema.getName());
  347. stmt.setString(2, table.getName());
  349. ResultSet colRset = stmt.executeQuery();
  351. Index primaryKey = null;
  353. while (colRset.next()) {
  354. if (primaryKey == null) {
  355. primaryKey = new Index(table);
  356. primaryKey.setName("PRIMARY");
  358. primaryKey.setIsPrimary(1);
  360. table.getIndices().add(primaryKey);
  362. table.setPrimaryKey(primaryKey);
  363. }
  365. IndexColumn indexColumn = new IndexColumn(primaryKey);
  366. indexColumn.setName(colRset.getString("COLUMN_NAME"));
  367. indexColumn.setColumnLength(0);
  368. indexColumn.setDescend(0);
  370. // find reference table column
  371. for (int j = 0; j < table.getColumns().size(); j++) {
  372. Column column = (Column) (table.getColumns().get(j));
  374. if (column.getName().compareToIgnoreCase(
  375. indexColumn.getName()) == 0) {
  376. indexColumn.setReferedColumn(column);
  377. break;
  378. }
  379. }
  381. primaryKey.getColumns().add(indexColumn);
  382. }
  384. stmt.close();
  385. } catch (Exception e) {
  386. Grt.getInstance().addErr(e.getMessage());
  387. }
  388. }
  390. private static String tableIndexSelect = "SELECT INDEX_NAME = A.name, "
  391. + " INDEX_TYPE = CASE WHEN ((A.status&16) = 16 OR (A.status2&512) = 512) THEN 'Clustered' "
  392. + "  WHEN (A.indid = 255) THEN 'Text/Image' "
  393. + "  ELSE 'NonClustered' END, "
  394. + " IS_UNIQUE = CASE WHEN ((A.status&2) = 2) THEN 1 ELSE 0 END, "
  395. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 1), "
  396. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 2), "
  397. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 3), "
  398. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 4), "
  399. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 5), "
  400. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 6), "
  401. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 7), "
  402. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 8), "
  403. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 9), "
  404. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 10), "
  405. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 11), "
  406. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 12), "
  407. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 13), "
  408. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 14), "
  409. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 15), "
  410. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 16), "
  411. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 17), "
  412. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 18), "
  413. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 19), "
  414. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 20), "
  415. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 21), "
  416. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 22), "
  417. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 23), "
  418. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 24), "
  419. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 25), "
  420. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 26), "
  421. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 27), "
  422. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 28), "
  423. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 29), "
  424. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 30), "
  425. + " INDEX_COL(USER_NAME(B.uid) + '.' + B.name, indid, 31) "
  426. + "FROM sysindexes A,  sysobjects B "
  427. + "WHERE A.indid > 0 AND A.indid < 255 AND A.status2 & 2 != 2 AND "
  428. + " B.id = A.id AND B.type = 'U' AND "
  429. + " USER_NAME(B.uid) = ? AND B.name=? " + "ORDER BY 1, 2, 3";
  431. protected void reverseEngineerTableIndices(Connection conn,
  432. Catalog catalog, Schema schema, Table table) {
  434. try {
  435. Grt.getInstance().addMsg("Fetching indices information.");
  436. Grt.getInstance().addMsgDetail(tableIndexSelect);
  438. PreparedStatement stmt = conn.prepareStatement(tableIndexSelect);
  439. stmt.setString(1, schema.getName());
  440. stmt.setString(2, table.getName());
  442. ResultSet rset = stmt.executeQuery();
  443. Index index = null;
  445. while (rset.next()) {
  446. String newIndexName = rset.getString("INDEX_NAME");
  448. index = new Index(table);
  449. index.setName(newIndexName);
  451. if (rset.getInt("IS_UNIQUE") != 0)
  452. index.setUnique(1);
  453. else
  454. index.setUnique(0);
  456. index.setDeferability(0);
  458. String indexType = rset.getString("INDEX_TYPE");
  459. if (indexType.equalsIgnoreCase("Clustered"))
  460. index.setClustered(1);
  461. else
  462. index.setClustered(0);
  464. int indexColumnPos = 4;
  465. String indexColumnName = rset.getString(indexColumnPos++);
  467. while (indexColumnPos < 31 + 4 && indexColumnName != null) {
  468. IndexColumn indexColumn = new IndexColumn(index);
  469. indexColumn.setName(indexColumnName);
  470. indexColumn.setColumnLength(0);
  471. indexColumn.setDescend(0);
  473. // find reference table column
  474. for (int j = 0; j < table.getColumns().size(); j++) {
  475. Column column = (Column) (table.getColumns().get(j));
  477. if (column.getName().compareToIgnoreCase(
  478. indexColumn.getName()) == 0) {
  479. indexColumn.setReferedColumn(column);
  480. break;
  481. }
  482. }
  484. index.getColumns().add(indexColumn);
  486. indexColumnName = rset.getString(indexColumnPos++);
  487. }
  489. table.getIndices().add(index);
  490. }
  492. stmt.close();
  493. } catch (Exception e) {
  494. Grt.getInstance().addErr(e.getMessage());
  495. }
  496. }
  498. private static String tableFKSelect = "SELECT CONSTRAINT_NAME = OBJECT_NAME(A.constrid), "
  499. + " REF_CATALOG_NAME = ISNULL(A.pmrydbname,DB_NAME()), "
  500. + " REF_SCHEMA_NAME = USER_NAME(B.uid), "
  501. + " REF_TABLE_NAME = OBJECT_NAME(A.reftabid), "
  502. + " COLUMN_COUNT = A.keycnt, "
  503. + " FK_COLUMN1 = COL_NAME(A.tableid, A.fokey1, DB_ID(A.frgndbname)), "
  504. + " COL_NAME(A.tableid, A.fokey2, DB_ID(A.frgndbname)), "
  505. + " COL_NAME(A.tableid, A.fokey3, DB_ID(A.frgndbname)), "
  506. + " COL_NAME(A.tableid, A.fokey4, DB_ID(A.frgndbname)), "
  507. + " COL_NAME(A.tableid, A.fokey5, DB_ID(A.frgndbname)), "
  508. + " COL_NAME(A.tableid, A.fokey6, DB_ID(A.frgndbname)), "
  509. + " COL_NAME(A.tableid, A.fokey7, DB_ID(A.frgndbname)), "
  510. + " COL_NAME(A.tableid, A.fokey8, DB_ID(A.frgndbname)), "
  511. + " COL_NAME(A.tableid, A.fokey9, DB_ID(A.frgndbname)), "
  512. + " COL_NAME(A.tableid, A.fokey10, DB_ID(A.frgndbname)), "
  513. + " COL_NAME(A.tableid, A.fokey11, DB_ID(A.frgndbname)), "
  514. + " COL_NAME(A.tableid, A.fokey12, DB_ID(A.frgndbname)), "
  515. + " COL_NAME(A.tableid, A.fokey13, DB_ID(A.frgndbname)), "
  516. + " COL_NAME(A.tableid, A.fokey14, DB_ID(A.frgndbname)), "
  517. + " COL_NAME(A.tableid, A.fokey15, DB_ID(A.frgndbname)), "
  518. + " COL_NAME(A.tableid, A.fokey16, DB_ID(A.frgndbname)), "
  519. + " REFERENCED_COLUMN1 = COL_NAME(A.reftabid, A.refkey1, DB_ID(A.pmrydbname)), "
  520. + " COL_NAME(A.reftabid, A.refkey2, DB_ID(A.pmrydbname)), "
  521. + " COL_NAME(A.reftabid, A.refkey3, DB_ID(A.pmrydbname)), "
  522. + " COL_NAME(A.reftabid, A.refkey4, DB_ID(A.pmrydbname)), "
  523. + " COL_NAME(A.reftabid, A.refkey5, DB_ID(A.pmrydbname)), "
  524. + " COL_NAME(A.reftabid, A.refkey6, DB_ID(A.pmrydbname)), "
  525. + " COL_NAME(A.reftabid, A.refkey7, DB_ID(A.pmrydbname)), "
  526. + " COL_NAME(A.reftabid, A.refkey8, DB_ID(A.pmrydbname)), "
  527. + " COL_NAME(A.reftabid, A.refkey9, DB_ID(A.pmrydbname)), "
  528. + " COL_NAME(A.reftabid, A.refkey10, DB_ID(A.pmrydbname)), "
  529. + " COL_NAME(A.reftabid, A.refkey11, DB_ID(A.pmrydbname)), "
  530. + " COL_NAME(A.reftabid, A.refkey12, DB_ID(A.pmrydbname)), "
  531. + " COL_NAME(A.reftabid, A.refkey13, DB_ID(A.pmrydbname)), "
  532. + " COL_NAME(A.reftabid, A.refkey14, DB_ID(A.pmrydbname)), "
  533. + " COL_NAME(A.reftabid, A.refkey15, DB_ID(A.pmrydbname)), "
  534. + " COL_NAME(A.reftabid, A.refkey16, DB_ID(A.pmrydbname)) "
  535. + "FROM sysreferences A, sysobjects B "
  536. + "WHERE USER_NAME(B.uid) = ? AND "
  537. + " A.tableid = OBJECT_ID(?) AND "
  538. + " A.reftabid = B.id AND (A.pmrydbname IS NULL) ";
  540. protected void reverseEngineerTableFKs(Connection conn, Catalog catalog,
  541. Schema schema, Table table) {
  543. try {
  544. Grt.getInstance().addMsg("Fetching FK information.");
  545. Grt.getInstance().addMsgDetail(tableFKSelect);
  547. PreparedStatement stmt = conn.prepareStatement(tableFKSelect);
  548. stmt.setString(1, schema.getName());
  549. stmt.setString(2, table.getName());
  551. ResultSet rset = stmt.executeQuery();
  553. ForeignKey foreignKey = null;
  555. while (rset.next()) {
  556. String newFkName = rset.getString("CONSTRAINT_NAME");
  558. foreignKey = new ForeignKey(table);
  559. foreignKey.setName(newFkName);
  561. foreignKey.setDeferability(0);
  563. foreignKey.setDeleteRule("NO ACTION");
  564. foreignKey.setUpdateRule("NO ACTION");
  566. foreignKey.setReferedTableSchemaName(rset
  567. .getString("REF_SCHEMA_NAME"));
  568. foreignKey
  569. .setReferedTableName(rset.getString("REF_TABLE_NAME"));
  571. int fkColumnPos = 6;
  572. int fkColumnCount = rset.getInt("COLUMN_COUNT");
  573. String refColumnName = rset.getString(fkColumnPos + 16);
  574. String fkColumnName = rset.getString(fkColumnPos);
  576. while (fkColumnPos < fkColumnCount + 6 && fkColumnName != null) {
  577. foreignKey.getReferedColumnNames().add(refColumnName);
  579. // find reference table column
  580. for (int j = 0; j < table.getColumns().size(); j++) {
  581. Column column = (Column) (table.getColumns().get(j));
  583. if (column.getName().compareToIgnoreCase(fkColumnName) == 0)
  584. foreignKey.getColumns().add(column);
  585. }
  587. refColumnName = rset.getString(fkColumnPos + 16);
  588. fkColumnName = rset.getString(fkColumnPos++);
  589. }
  591. table.getForeignKeys().add(foreignKey);
  592. }
  594. stmt.close();
  595. } catch (Exception e) {
  596. Grt.getInstance().addErr(e.getMessage());
  597. }
  598. }
  600. private static String viewSelect = "SELECT VIEW_NAME = B.name, VIEW_DEFINITION = A.text "
  601. + "FROM syscomments A,sysobjects B "
  602. + "WHERE USER_NAME(B.uid) = ? AND " + "B.type='V' AND A.id=B.id";
  604. protected void reverseEngineerViews(Connection conn, Catalog catalog,
  605. Schema schema) throws Exception {
  607. Grt.getInstance().addMsg(
  608. "Fetch all views of the schema " + schema.getName() + ".");
  609. Grt.getInstance().addMsgDetail(viewSelect);
  610. Grt.getInstance().flushMessages();
  612. PreparedStatement stmt = conn.prepareStatement(viewSelect);
  613. stmt.setString(1, schema.getName());
  615. ResultSet rset = stmt.executeQuery();
  617. while (rset.next()) {
  618. // Create new view
  619. View view = new View(schema);
  620. schema.getViews().add(view);
  622. view.setName(rset.getString("VIEW_NAME"));
  624. Grt.getInstance().addMsg("Processing view " + view.getName() + ".");
  626. view.setQueryExpression(rset.getString("VIEW_DEFINITION"));
  628. view.setWithCheckCondition(0);
  629. }
  631. stmt.close();
  633. Grt.getInstance().addMsg("Views fetched.");
  634. }
  636. private static String procedureCountSelect = "SELECT NUM = COUNT(*) "
  637. + "FROM sysobjects O "
  638. + "WHERE USER_NAME(O.uid) = ? AND O.type = 'P'";
  640. private static String procedureSelect = "SELECT ROUTINE_NAME = O.name, "
  641. + " ROUTINE_DEFINITION = A.text "
  642. + "FROM syscomments A, sysobjects O "
  643. + "WHERE USER_NAME(O.uid) = ? AND A.id=O.id AND O.type = 'P'";
  645. protected int reverseEngineerProcedures(Connection conn, Catalog catalog,
  646. Schema schema) throws Exception {
  647. int spCount = 0;
  648. int currentSpNumber = 0;
  650. Grt.getInstance().addMsg(
  651. "Fetch count of stored procedures of the schema "
  652. + schema.getName() + ".");
  653. Grt.getInstance().addMsgDetail(procedureCountSelect);
  655. try {
  656. PreparedStatement stmt = conn
  657. .prepareStatement(procedureCountSelect);
  658. stmt.setString(1, schema.getName());
  660. ResultSet rset = stmt.executeQuery();
  662. if (rset.next()) {
  663. spCount = rset.getInt("NUM");
  664. }
  666. Grt.getInstance().addMsg(
  667. "Fetching " + spCount
  668. + " stored procedure(s) of the schema "
  669. + schema.getName() + ".");
  670. Grt.getInstance().addMsgDetail(procedureSelect);
  671. Grt.getInstance().flushMessages();
  673. stmt = conn.prepareStatement(procedureSelect);
  674. stmt.setString(1, schema.getName());
  676. rset = stmt.executeQuery();
  678. while (rset.next()) {
  679. // Create new view
  680. Routine proc = new Routine(schema);
  681. schema.getRoutines().add(proc);
  683. proc.setName(rset.getString("ROUTINE_NAME"));
  685. currentSpNumber++;
  687. Grt.getInstance().addProgress(
  688. "Processing procedure " + proc.getName() + ".",
  689. (currentSpNumber * 100) / spCount);
  690. if (Grt.getInstance().flushMessages() != 0) {
  691. Grt.getInstance().addMsg("Migration canceled by user.");
  692. return 1;
  693. }
  695. Grt.getInstance().addMsg(
  696. "Processing procedure " + proc.getName() + ".");
  698. proc.setRoutineType("PROCEDURE");
  700. proc.setRoutineCode(rset.getString("ROUTINE_DEFINITION"));
  701. }
  703. stmt.close();
  705. Grt.getInstance().addMsg("Routines fetched.");
  707. Grt.getInstance().addProgress("", -1);
  709. } catch (Exception e) {
  710. Grt.getInstance().addMsg("Stored procedures cannot be fetched.");
  711. Grt.getInstance().addMsgDetail(e.getMessage());
  712. }
  714. return 0;
  715. }
  716. }