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

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

MySQL数据库

开发平台：

SQL

ReverseEngineeringMaxdb.java：源码内容
  1. package com.mysql.grt.modules;
  3. import java.sql.*;
  5. import com.mysql.grt.*;
  6. import com.mysql.grt.db.maxdb.*;
  8. /**
  9.  * GRT Reverse Engineering Class for MaxDB
  10.  * 
  11.  * @author Mike
  12.  * @version 1.0, 11/26/04
  13.  * 
  14.  */
  15. public class ReverseEngineeringMaxdb 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(ReverseEngineeringMaxdb.class,
  25. "ReverseEngineering");
  26. }
  28. /* MaxDB <=7.5 - no SQL schemata, schemata (namespaces) based on users */
  29. private static String schemataSelect75 = "SELECT USERNAME FROM USERS ORDER BY USERNAME ASC";
  31. /*
  32.  * MaxDB >=7.6 - real SQL schema and CREATE SCHEMA, in coexistance with the
  33.  * user logic
  34.  */
  35. private static String schemataSelect76 = "SELECT SCHEMANAME FROM SCHEMAS ORDER BY SCHEMANAME ASC";
  37. /**
  38.  * Returns a list of all schemata from the given JDBC connection
  39.  * 
  40.  * @param jdbcDriver
  41.  *            the class name of the JDBC driver
  42.  * @param jdbcConnectionString
  43.  *            a JDBC connection string
  44.  * @return returns a GRT XML string containing a list of schemata names
  45.  */
  46. public static GrtStringList getSchemata(
  47. com.mysql.grt.db.mgmt.Connection dbConn) throws Exception {
  49. String schemataSelect = "";
  51. // connect to the database
  52. Connection conn = establishConnection(dbConn);
  54. // As of 7.6 MaxDB has support for real SQL schemata (CREATE SCHEMA...)
  55. DatabaseMetaData metaData = conn.getMetaData();
  57. if ((metaData.getDatabaseMajorVersion() >= 7)
  58. && (metaData.getDatabaseMinorVersion() >= 6)) {
  59. schemataSelect = schemataSelect76;
  60. } else {
  61. schemataSelect = schemataSelect75;
  62. }
  64. Grt.getInstance().addMsg("Fetching schemata list...");
  65. Grt.getInstance().addMsgDetail(schemataSelect);
  66. Grt.getInstance().flushMessages();
  68. GrtStringList schemataList = new GrtStringList();
  70. Statement stmt = conn.createStatement();
  71. ResultSet rset = stmt.executeQuery(schemataSelect);
  72. while (rset.next()) {
  73. schemataList.add(rset.getString(1));
  74. }
  75. stmt.close();
  76. conn.close();
  78. Grt.getInstance().addMsg("Return schemata list.");
  79. Grt.getInstance().flushMessages();
  81. return schemataList;
  82. }
  84. /**
  85.  * Does the reverse engineering of the given schematas over the JDBC
  86.  * connection and returns the GRT objects
  87.  * 
  88.  * @param jdbcDriver
  89.  *            the class name of the JDBC driver
  90.  * @param jdbcConnectionString
  91.  *            a JDBC connection string
  92.  * @param schemataList
  93.  *            list of schematas to be reverse engineered
  94.  * @return returns a GRT XML string containing a the reverse engineered
  95.  *         objects
  96.  */
  97. public static com.mysql.grt.db.Catalog reverseEngineer(
  98. com.mysql.grt.db.mgmt.Connection dbConn, GrtStringList schemataList)
  99. throws Exception {
  101. boolean reverseEngineerOnlyTableObjects = (Grt.getInstance()
  102. .getGrtGlobalAsInt(
  103. "/migration/applicationData/"
  104. + "reverseEngineerOnlyTableObjects") == 1);
  106. // connect to the database
  107. Connection conn = establishConnection(dbConn);
  109. // create reveng instance
  110. ReverseEngineeringMaxdb revEng = new ReverseEngineeringMaxdb();
  112. Catalog catalog = new Catalog(null);
  113. catalog.setName("MaxdbCatalog");
  114. catalog.setVersion(getVersion(dbConn));
  116. Grt.getInstance().addMsg("Build simple MaxDB datatypes.");
  117. Grt.getInstance().flushMessages();
  118. revEng.buildSimpleDatatypes(dbConn, catalog);
  120. for (int i = 0; i < schemataList.size(); i++) {
  121. Schema schema = new Schema(catalog);
  122. schema.setName((String) (schemataList.get(i)));
  123. catalog.getSchemata().add(schema);
  125. // Get Tables
  126. if (revEng.reverseEngineerTables(conn, catalog, schema) == 0
  127. && !reverseEngineerOnlyTableObjects) {
  129. // Get Views
  130. revEng.reverseEngineerViews(conn, catalog, schema);
  132. // Get SPs
  133. if (revEng.reverseEngineerProcedures(conn, catalog, schema) == 0) {
  135. // Get Sequences
  136. if (revEng.reverseEngineerSequences(conn, catalog, schema) == 0) {
  138. // Get table Synonyms
  139. revEng.reverseEngineerSynonyms(conn, catalog, schema);
  141. }
  142. }
  143. }
  144. }
  146. // make sure the Fks use real references instead of
  147. // text names where possible
  148. revEng.reverseEngineerUpdateFkReferences(catalog);
  150. return catalog;
  151. }
  153. protected void buildSimpleDatatypes(
  154. com.mysql.grt.db.mgmt.Connection dbConn, Catalog catalog) {
  155. com.mysql.grt.db.mgmt.Driver driver = dbConn.getDriver();
  156. com.mysql.grt.db.mgmt.Rdbms rdbms = (com.mysql.grt.db.mgmt.Rdbms) driver
  157. .getOwner();
  158. com.mysql.grt.db.SimpleDatatypeList rdbmsDatatypeList = rdbms
  159. .getSimpleDatatypes();
  160. com.mysql.grt.db.SimpleDatatypeList catalogDatatypeList = new com.mysql.grt.db.SimpleDatatypeList();
  162. for (int i = 0; i < rdbmsDatatypeList.size(); i++) {
  163. catalogDatatypeList.add(rdbmsDatatypeList.get(i));
  164. }
  166. catalog.setSimpleDatatypes(catalogDatatypeList);
  167. }
  169. private static String tableCountSelect75 = "SELECT COUNT(*) AS TABLECOUNT FROM TABLES "
  170. + "WHERE OWNER=? AND TYPE='TABLE'";
  172. private static String tableCountSelect76 = "SELECT COUNT(*) AS TABLECOUNT FROM TABLES "
  173. + "WHERE SCHEMANAME=? AND TYPE='TABLE'";
  175. private static String tableSelect75 = "SELECT * FROM TABLES "
  176. + "WHERE OWNER=? AND TYPE='TABLE' ORDER BY TABLENAME ASC";
  178. private static String tableSelect76 = "SELECT * FROM TABLES "
  179. + "WHERE SCHEMANAME=? AND TYPE = 'TABLE' ORDER BY TABLENAME ASC";
  181. protected int reverseEngineerTables(Connection conn, Catalog catalog,
  182. Schema schema) throws Exception {
  184. int tableCount = 0;
  185. int currentTableNumber = 0;
  186. String sqlSelect = "";
  188. sqlSelect = (this.useRealSchema(conn)) ? tableCountSelect76
  189. : tableCountSelect75;
  191. Grt.getInstance().addMsg(
  192. "Fetch the number of tables in the schema " + schema.getName()
  193. + ".");
  194. Grt.getInstance().addMsgDetail(sqlSelect);
  196. PreparedStatement stmt = conn.prepareStatement(sqlSelect);
  197. stmt.setString(1, schema.getName());
  199. ResultSet tblRset = stmt.executeQuery();
  200. if (tblRset.next()) {
  201. tableCount = tblRset.getInt("TABLECOUNT");
  202. }
  203. stmt.close();
  205. sqlSelect = (this.useRealSchema(conn)) ? tableSelect76 : tableSelect75;
  207. Grt.getInstance().addMsg(
  208. "Fetching " + tableCount + " table(s) of the schema "
  209. + schema.getName() + ".");
  210. Grt.getInstance().addMsgDetail(sqlSelect);
  211. Grt.getInstance().flushMessages();
  213. stmt = conn.prepareStatement(sqlSelect);
  214. stmt.setString(1, schema.getName());
  216. tblRset = stmt.executeQuery();
  218. while (tblRset.next()) {
  219. // Create new table
  220. Table table = new Table(schema);
  221. schema.getTables().add(table);
  223. currentTableNumber++;
  225. table.setName(tblRset.getString("TABLENAME"));
  227. Grt.getInstance().addProgress(
  228. "Processing table " + table.getName() + ".",
  229. (currentTableNumber * 100) / tableCount);
  230. if (Grt.getInstance().flushMessages() != 0) {
  231. Grt.getInstance().addMsg("Migration canceled by user.");
  232. return 1;
  233. }
  235. table.setNoFixedLengthColumn((tblRset.getString("DYNAMIC")
  236. .compareToIgnoreCase("NO") == 0) ? 1 : 0);
  237. table.setSample((tblRset.getString("SAMPLE_ROWS") == "") ? tblRset
  238. .getString("SAMPLE_PERCENT") : tblRset
  239. .getString("SAMPLE_ROWS"));
  240. table.setAlterDate(tblRset.getString("ALTERDATE"));
  241. table.setAlterTime(tblRset.getString("ALTERTIME"));
  242. table.setArchive(tblRset.getString("ARCHIVE"));
  243. table.setComment(tblRset.getString("COMMENT"));
  244. table.setCreateDate(tblRset.getString("CREATEDATE"));
  245. table.setCreateTime(tblRset.getString("CREATETIME"));
  246. // TODO: this needs to be escaped, otherwise it breaks the XML
  247. // table.setTableid(tblRset.getString("TABLEID"));
  248. table.setUnloaded(tblRset.getString("UNLOADED"));
  249. table.setUpdStatDate(tblRset.getString("UPDSTATDATE"));
  250. table.setUpdStatTime(tblRset.getString("UPDSTATTIME"));
  251. table.setVariableColumns(tblRset.getString("VARIABLE_COLUMNS"));
  252. table.setPrivileges(tblRset.getString("PRIVILEGES"));
  254. reverseEngineerTableColumns(conn, catalog, schema, table);
  256. reverseEngineerTablePK(conn, catalog, schema, table);
  258. reverseEngineerTableIndices(conn, catalog, schema, table);
  260. reverseEngineerTableFKs(conn, catalog, schema, table);
  262. reverseEngineerTableTriggers(conn, catalog, schema, table);
  263. }
  265. Grt.getInstance().addProgress("", -1);
  266. Grt.getInstance().flushMessages();
  268. stmt.close();
  270. return 0;
  271. }
  273. private static String tableColumnSelect75 = "SELECT * FROM COLUMNS "
  274. + "WHERE OWNER=? AND TABLENAME=? "
  275. + "ORDER BY TABLENAME ASC, POS ASC, KEYPOS ASC";
  277. private static String tableColumnSelect76 = "SELECT * FROM COLUMNS "
  278. + "WHERE SCHEMANAME=? AND TABLENAME=? "
  279. + "ORDER BY TABLENAME ASC, POS ASC, KEYPOS ASC";
  281. protected void reverseEngineerTableColumns(Connection conn,
  282. Catalog catalog, Schema schema, Table table) {
  284. String defaultValue = "";
  286. try {
  287. Grt.getInstance().addMsg("Fetching column information.");
  288. Grt.getInstance().addMsgDetail(
  289. (this.useRealSchema(conn)) ? tableColumnSelect76
  290. : tableColumnSelect75);
  292. PreparedStatement stmt = conn.prepareStatement((this
  293. .useRealSchema(conn)) ? tableColumnSelect76
  294. : tableColumnSelect75);
  295. stmt.setString(1, schema.getName());
  296. stmt.setString(2, table.getName());
  298. ResultSet colRset = stmt.executeQuery();
  299. while (colRset.next()) {
  300. // create new column
  301. Column column = new Column(table);
  302. table.getColumns().add(column);
  304. column.setName(colRset.getString("COLUMNNAME"));
  305. column.setDatatypeName(colRset.getString("DATATYPE"));
  306. column.setComment(colRset.getString("COMMENT"));
  308. column.setDefaultFunction(colRset.getString("DEFAULTFUNCTION"));
  310. defaultValue = colRset.getString("DEFAULT");
  311. column.setDefaultValue(defaultValue);
  312. if ((colRset.wasNull())
  313. && (colRset.getString("NULLABLE").compareToIgnoreCase(
  314. "YES") == 0)) {
  315. column.setDefaultValueIsNull(1);
  316. } else {
  317. column.setDefaultValueIsNull(0);
  318. }
  320. if (colRset.getString("NULLABLE").compareToIgnoreCase("YES") == 0) {
  321. column.setIsNullable(1);
  322. } else {
  323. column.setIsNullable(0);
  324. }
  326. column.setCodeType(colRset.getString("CODETYPE"));
  328. // TODO: check the meaning of length
  329. // MaxDB manual: Length or precision of column
  330. column.setLength(colRset.getInt("LEN"));
  331. column.setPrecision(colRset.getInt("LEN"));
  333. // TODO: check meaning - OK for FIXED
  334. column.setScale(colRset.getInt("DEC"));
  336. column.setAlterDate(colRset.getString("ALTERDATE"));
  337. column.setAlterTime(colRset.getString("ALTERTIME"));
  338. column.setCreateDate(colRset.getString("CREATEDATE"));
  339. column.setCreateTime(colRset.getString("CREATETIME"));
  340. column.setPrivileges(colRset.getString("COLUMNPRIVILEGES"));
  341. column.setDomainOwner(colRset.getString("DOMAINOWNER"));
  342. column.setDomainName(colRset.getString("DOMAINNAME"));
  344. // Get Simple Type
  345. int datatypeIndex = catalog.getSimpleDatatypes()
  346. .getIndexOfName(column.getDatatypeName());
  348. if (datatypeIndex > -1) {
  349. column.setSimpleType(catalog.getSimpleDatatypes().get(
  350. datatypeIndex));
  351. } else {
  352. column.setSimpleType(catalog.getSimpleDatatypes().get(
  353. catalog.getSimpleDatatypes().getIndexOfName(
  354. "VARCHAR")));
  355. column.setLength(255);
  357. Grt.getInstance().addMsg(
  358. "WARNING: The datatype " + column.getDatatypeName()
  359. + " was not been defined yet.");
  360. }
  362. }
  364. stmt.close();
  365. } catch (Exception e) {
  366. Grt.getInstance().addErr(e.getMessage());
  367. }
  368. }
  370. private static String tablePKSelect75 = "SELECT COLUMNNAME FROM COLUMNS "
  371. + "WHERE OWNER=? AND TABLENAME=? AND MODE='KEY' "
  372. + "ORDER BY KEYPOS ASC";
  374. private static String tablePKSelect76 = "SELECT COLUMNNAME FROM COLUMNS "
  375. + "WHERE SCHEMANAME=? AND TABLENAME=? AND MODE='KEY' "
  376. + "ORDER BY KEYPOS ASC";
  378. protected void reverseEngineerTablePK(Connection conn, Catalog catalog,
  379. Schema schema, Table table) throws Exception {
  381. String tablePKSelect = "";
  383. try {
  385. Grt.getInstance().addMsg("Fetching primary key information.");
  386. tablePKSelect = (this.useRealSchema(conn)) ? tablePKSelect76
  387. : tablePKSelect75;
  388. Grt.getInstance().addMsgDetail(tablePKSelect);
  390. PreparedStatement stmt = conn.prepareStatement(tablePKSelect);
  391. stmt.setString(1, schema.getName());
  392. stmt.setString(2, table.getName());
  394. ResultSet colRset = stmt.executeQuery();
  396. Index primaryKey = null;
  398. while (colRset.next()) {
  399. if (primaryKey == null) {
  400. primaryKey = new Index(table);
  401. primaryKey.setName("PRIMARY");
  403. primaryKey.setIsPrimary(1);
  405. table.getIndices().add(primaryKey);
  406. table.setPrimaryKey(primaryKey);
  407. }
  409. String indexColumnName = colRset.getString("COLUMNNAME");
  410. int index = table.getColumns().getIndexOfName(indexColumnName);
  412. if (index > -1) {
  413. // create new index column
  414. IndexColumn indexColumn = new IndexColumn(primaryKey);
  415. indexColumn.setName(indexColumnName);
  417. // find reference table column
  418. for (int j = 0; j < table.getColumns().size(); j++) {
  419. Column column = (Column) (table.getColumns().get(j));
  421. if (column.getName().compareToIgnoreCase(
  422. indexColumn.getName()) == 0) {
  423. indexColumn.setReferedColumn(column);
  424. break;
  425. }
  426. }
  428. primaryKey.getColumns().add(indexColumn);
  430. }
  431. }
  433. stmt.close();
  434. } catch (Exception e) {
  435. Grt.getInstance().addErr(e.getMessage());
  436. }
  438. }
  440. private static String tableIndexSelect75 = "SELECT"
  441. + "  idx.OWNER, idx.INDEXNAME, "
  442. + "  idx.TYPE as INDEX_TYPE, idx.CREATEDATE as INDEX_CREATEDATE, "
  443. + "  idx.CREATETIME as INDEX_CREATETIME, idx.INDEX_USED, "
  444. + "  idx.DISABLED, idx.COMMENT as INDEX_COMMENT, "
  445. + "  idxcols.COLUMNNAME, "
  446. + "  idxcols.SORT, idxcols.COLUMNNO, idxcols.DATATYPE, idxcols.LEN, "
  447. + "  idxcols.CREATEDATE as COLUMN_CREATEDATE, idxcols.CREATETIME as COLUMN_CREATETIME, "
  448. + "  idxcols.COMMENT as COLUMN_COMMENT " + "FROM "
  449. + "  INDEXES AS idx, INDEXCOLUMNS as idxcols " + "WHERE "
  450. + "  idx.OWNER=? " + "  AND idx.TABLENAME=? "
  451. + "  AND idx.OWNER = idxcols.OWNER "
  452. + "  AND idx.TABLENAME = idxcols.TABLENAME "
  453. + "  AND idx.INDEXNAME = idxcols.INDEXNAME " + "ORDER BY "
  454. + "  INDEXNAME ASC, COLUMNNO ASC";
  456. private static String tableIndexSelect76 = "SELECT "
  457. + "  idx.SCHEMANAME, idx.OWNER, idx.INDEXNAME, idx.FILEID as INDEX_FILEID, "
  458. + "  idx.TYPE as INDEX_TYPE, idx.CREATEDATE as INDEX_CREATEDATE, "
  459. + "  idx.CREATETIME as INDEX_CREATETIME, idx.INDEX_USED, idx.FILESTATE as INDEX_FILESTATE, "
  460. + "  idx.DISABLED, idx.COMMENT as INDEX_COMMENT, "
  461. + "  idxcols.FILEID as COLUMN_FILEID, idxcols.COLUMNNAME, "
  462. + "  idxcols.FILESTATE as COLUMN_FILESTATE, "
  463. + "  idxcols.SORT, idxcols.COLUMNNO, idxcols.DATATYPE, idxcols.LEN, "
  464. + "  idxcols.CREATEDATE as COLUMN_CREATEDATE, idxcols.CREATETIME as COLUMN_CREATETIME, "
  465. + "  idxcols.COMMENT as COLUMN_COMMENT " + "FROM "
  466. + "  INDEXES AS idx, INDEXCOLUMNS as idxcols " + "WHERE "
  467. + "  idx.SCHEMANAME=? " + "  AND idx.TABLENAME=? "
  468. + "  AND idx.SCHEMANAME = idxcols.SCHEMANAME "
  469. + "  AND idx.TABLENAME = idxcols.TABLENAME "
  470. + "  AND idx.INDEXNAME = idxcols.INDEXNAME " + "ORDER BY "
  471. + "  INDEXNAME ASC, COLUMNNO ASC";
  473. private static String tableIndexStatisticsSelect75 = "SELECT * FROM INDEXSTATISTICS WHERE "
  474. + "OWNER=? AND TABLENAME=? AND INDEXNAME=?";
  476. private static String tableIndexStatisticsSelect76 = "SELECT * FROM INDEXSTATISTICS WHERE "
  477. + "SCHEMANAME=? AND TABLENAME=? AND INDEXNAME=?";
  479. protected void reverseEngineerTableIndices(Connection conn,
  480. Catalog catalog, Schema schema, Table table) {
  482. String tableIndexSelect = "";
  483. String tableIndexStatisticsSelect = "";
  485. try {
  487. if (this.useRealSchema(conn)) {
  488. tableIndexSelect = tableIndexSelect76;
  489. tableIndexStatisticsSelect = tableIndexStatisticsSelect76;
  490. } else {
  491. tableIndexSelect = tableIndexSelect75;
  492. tableIndexStatisticsSelect = tableIndexStatisticsSelect75;
  493. }
  495. Grt.getInstance().addMsg("Fetching indices information.");
  496. Grt.getInstance().addMsgDetail(tableIndexSelect);
  497. Grt.getInstance().addMsgDetail(tableIndexStatisticsSelect);
  499. PreparedStatement stmt = conn.prepareStatement(tableIndexSelect);
  500. stmt.setString(1, schema.getName());
  501. stmt.setString(2, table.getName());
  503. ResultSet rset = stmt.executeQuery();
  505. String indexName = "";
  506. Index index = null;
  508. while (rset.next()) {
  509. String newIndexName = rset.getString("INDEXNAME");
  511. if (indexName.compareTo(newIndexName) != 0) {
  512. if (index != null)
  513. table.getIndices().add(index);
  515. index = new Index(table);
  516. index.setName(newIndexName);
  517. indexName = newIndexName;
  519. /* Properties from the sytem table INDEXES */
  520. index.setCreateDate(rset.getString("INDEX_CREATEDATE"));
  521. index.setCreateTime(rset.getString("INDEX_CREATETIME"));
  522. index.setComment(rset.getString("INDEX_COMMENT"));
  523. index.setDeferability(0);
  525. if (rset.getString("DISABLED").compareToIgnoreCase("YES") == 0) {
  526. index.setDisabled(1);
  527. } else {
  528. index.setDisabled(0);
  529. }
  531. if (this.useRealSchema(conn)) {
  532. // TODO: this needs to be escaped, otherwise it breaks
  533. // the XML
  534. // index.setFileid(rset.getString("INDEX_FILEID"));
  535. /* TODO: currently SAP does not document the meaning */
  536. index.setFilestate(rset.getString("INDEX_FILESTATE"));
  537. }
  538. index.setIndexType(rset.getString("INDEX_TYPE"));
  540. if (rset.getInt("INDEX_USED") > 0) {
  541. index.setIndexUsed(1);
  542. } else {
  543. index.setIndexUsed(0);
  544. }
  546. if (rset.getString("INDEX_TYPE").compareToIgnoreCase(
  547. "UNIQUE") == 0) {
  548. index.setUnique(1);
  549. } else {
  550. index.setUnique(0);
  551. }
  553. // Index statistics
  554. PreparedStatement stmtStats = conn
  555. .prepareStatement(tableIndexStatisticsSelect);
  556. stmtStats.setString(1, schema.getName());
  557. stmtStats.setString(2, table.getName());
  558. stmtStats.setString(3, index.getName());
  560. // That code is ugly, but don't blame me for MaxDB's strange
  561. // storage
  562. // and Java's clean code philosophy - I love PHP ;-)
  564. String valueDesc = "";
  565. ResultSet rsetStats = stmtStats.executeQuery();
  566. while (rsetStats.next()) {
  567. valueDesc = rsetStats.getString("DESCRIPTION");
  569. if (valueDesc
  570. .compareToIgnoreCase("Avg primary keys per list") == 0) {
  571. index.setAvgNumPkPerList(rsetStats
  572. .getInt("NUMERIC_VALUE"));
  574. } else if (valueDesc
  575. .compareToIgnoreCase("Avg secondary key length") == 0) {
  576. index.setAverageSkLength(rsetStats
  577. .getInt("NUMERIC_VALUE"));
  579. } else if (valueDesc
  580. .compareToIgnoreCase("Avg separator length") == 0) {
  581. index.setAvgSeperatorLength(rsetStats
  582. .getInt("NUMERIC_VALUE"));
  584. } else if (valueDesc.compareToIgnoreCase("Filetype") == 0) {
  585. index.setFilestate(rsetStats
  586. .getString("CHAR_VALUE"));
  588. } else if (valueDesc
  589. .compareToIgnoreCase("Index levels") == 0) {
  590. index.setIndexLevels(rsetStats
  591. .getInt("NUMERIC_VALUE"));
  593. } else if (valueDesc.compareToIgnoreCase("Index pages") == 0) {
  594. index.setIndexPages(rsetStats
  595. .getInt("NUMERIC_VALUE"));
  597. } else if (valueDesc.compareToIgnoreCase("Leaf  pages") == 0) {
  598. index.setLeafPages(rsetStats
  599. .getInt("NUMERIC_VALUE"));
  601. } else if (valueDesc
  602. .compareToIgnoreCase("Max primary keys per list") == 0) {
  603. index.setMaxNumPkPerList(rsetStats
  604. .getInt("NUMERIC_VALUE"));
  606. } else if (valueDesc
  607. .compareToIgnoreCase("Max secondary key length") == 0) {
  608. index.setMaxSkLength(rsetStats
  609. .getInt("NUMERIC_VALUE"));
  611. } else if (valueDesc
  612. .compareToIgnoreCase("Max separator length") == 0) {
  613. index.setMaxSeperatorLength(rsetStats
  614. .getInt("NUMERIC_VALUE"));
  616. } else if (valueDesc
  617. .compareToIgnoreCase("Min primary keys per list") == 0) {
  618. index.setMinNumPkPerList(rsetStats
  619. .getInt("NUMERIC_VALUE"));
  621. } else if (valueDesc
  622. .compareToIgnoreCase("Min secondary key length") == 0) {
  623. index.setMinSkLength(rsetStats
  624. .getInt("NUMERIC_VALUE"));
  626. } else if (valueDesc
  627. .compareToIgnoreCase("Min separator length") == 0) {
  628. index.setMinSeperatorLength(rsetStats
  629. .getInt("NUMERIC_VALUE"));
  631. } else if (valueDesc
  632. .compareToIgnoreCase("Primary keys") == 0) {
  633. index.setNumRowsPk(rsetStats
  634. .getInt("NUMERIC_VALUE"));
  636. } else if (valueDesc.compareToIgnoreCase("Root pno") == 0) {
  637. index
  638. .setRootPage(rsetStats
  639. .getInt("NUMERIC_VALUE"));
  641. } else if (valueDesc
  642. .compareToIgnoreCase("Secondary keys (index lists)") == 0) {
  643. index.setNumDistinctValues(rsetStats
  644. .getInt("NUMERIC_VALUE"));
  646. } else if (valueDesc
  647. .compareToIgnoreCase("Space used in all   pages (%)") == 0) {
  648. index.setTotalSpaceUsed(rsetStats
  649. .getInt("NUMERIC_VALUE"));
  651. } else if (valueDesc
  652. .compareToIgnoreCase("Space used in index pages (%)") == 0) {
  653. index.setIndexPagesSpace(rsetStats
  654. .getInt("NUMERIC_VALUE"));
  656. } else if (valueDesc
  657. .compareToIgnoreCase("Space used in index pages (%) max") == 0) {
  658. index.setIndexPageSpaceMax(rsetStats
  659. .getInt("NUMERIC_VALUE"));
  661. } else if (valueDesc
  662. .compareToIgnoreCase("Space used in index pages (%) min") == 0) {
  663. index.setIndexPageSpaceMin(rsetStats
  664. .getInt("NUMERIC_VALUE"));
  666. } else if (valueDesc
  667. .compareToIgnoreCase("Space used in leaf  pages (%)") == 0) {
  668. index.setLeafPagesSpace(rsetStats
  669. .getInt("NUMERIC_VALUE"));
  671. } else if (valueDesc
  672. .compareToIgnoreCase("Space used in leaf  pages (%) max") == 0) {
  673. index.setLeafPagesSpaceMax(rsetStats
  674. .getInt("NUMERIC_VALUE"));
  676. } else if (valueDesc
  677. .compareToIgnoreCase("Space used in leaf  pages (%) min") == 0) {
  678. index.setLeafPagesSpaceMin(rsetStats
  679. .getInt("NUMERIC_VALUE"));
  681. } else if (valueDesc
  682. .compareToIgnoreCase("Space used in root  page  (%)") == 0) {
  683. index.setRootPageSpace(rsetStats
  684. .getInt("NUMERIC_VALUE"));
  686. } else if (valueDesc.compareToIgnoreCase("Used  pages") == 0) {
  687. index.setUsedPages(rsetStats
  688. .getInt("NUMERIC_VALUE"));
  690. } else if (valueDesc
  691. .compareToIgnoreCase("Values with selectivity <=  1%") == 0) {
  692. index.setSelectivityLess1Percent(rsetStats
  693. .getInt("NUMERIC_VALUE"));
  695. } else if (valueDesc
  696. .compareToIgnoreCase("Values with selectivity <=  5%") == 0) {
  697. index.setSelectivityLess5Percent(rsetStats
  698. .getInt("NUMERIC_VALUE"));
  700. } else if (valueDesc
  701. .compareToIgnoreCase("Values with selectivity <= 10%") == 0) {
  702. index.setSelectivityLess10Percent(rsetStats
  703. .getInt("NUMERIC_VALUE"));
  705. } else if (valueDesc
  706. .compareToIgnoreCase("Values with selectivity <= 25%") == 0) {
  707. index.setSelectivityLess25Percent(rsetStats
  708. .getInt("NUMERIC_VALUE"));
  710. } else if (valueDesc
  711. .compareToIgnoreCase("Values with selectivity >  25%") == 0) {
  712. index.setSelectivityGreater25Percent(rsetStats
  713. .getInt("NUMERIC_VALUE"));
  715. }
  716. }
  718. }
  720. IndexColumn indexColumn = new IndexColumn(index);
  721. indexColumn.setName(rset.getString("COLUMNNAME"));
  723. indexColumn.setColumnLength(rset.getInt("LEN"));
  724. indexColumn.setComment(rset.getString("COLUMN_COMMENT"));
  725. indexColumn.setCreateDate(rset.getString("COLUMN_CREATEDATE"));
  726. indexColumn.setCreateTime(rset.getString("COLUMN_CREATETIME"));
  728. if (rset.getString("SORT").compareToIgnoreCase("ASC") == 0) {
  729. indexColumn.setDescend(1);
  730. } else {
  731. indexColumn.setDescend(0);
  732. }
  734. if (this.useRealSchema(conn)) {
  735. // TODO: this needs to be escaped, otherwise it breaks the
  736. // XML
  737. // indexColumn.setFileid(rset.getString("COLUMN_FILEID"));
  738. indexColumn
  739. .setFilestate(rset.getString("COLUMN_FILESTATE"));
  740. }
  742. // find reference table column
  743. for (int j = 0; j < table.getColumns().size(); j++) {
  744. Column column = (Column) (table.getColumns().get(j));
  746. if (column.getName().compareTo(indexColumn.getName()) == 0) {
  747. indexColumn.setReferedColumn(column);
  748. break;
  749. }
  750. }
  752. index.getColumns().add(indexColumn);
  753. }
  755. if (index != null)
  756. table.getIndices().add(index);
  758. stmt.close();
  759. } catch (Exception e) {
  760. Grt.getInstance().addErr(e.getMessage());
  761. }
  762. }
  764. private static String tableFKSelect75 = "SELECT "
  765. + "  fk.OWNER, fk.TABLENAME, fk.FKEYNAME, fk.RULE, "
  766. + "  fk.CREATEDATE, fk.CREATETIME, "
  767. + "  fkcols.COLUMNNAME, fkcols.REFOWNER, "
  768. + "  fkcols.REFTABLENAME, fkcols.REFCOLUMNNAME, fkcols.RULE "
  769. + "FROM " + "  FOREIGNKEYS as fk, "
  770. + "  FOREIGNKEYCOLUMNS as fkcols " + "WHERE "
  771. + "  fk.OWNER=? AND fk.TABLENAME=?"
  772. + "  AND fk.OWNER = fkcols.OWNER "
  773. + "  AND fk.TABLENAME = fkcols.TABLENAME "
  774. + "  AND fk.FKEYNAME = fkcols.FKEYNAME " + "ORDER BY "
  775. + "  FKEYNAME ASC";
  777. private static String tableFKSelect76 = "SELECT "
  778. + "  fk.SCHEMANAME, fk.OWNER, fk.TABLENAME, fk.FKEYNAME, fk.RULE, "
  779. + "  fk.CREATEDATE, fk.CREATETIME, "
  780. + "  fkcols.COLUMNNAME, fkcols.REFSCHEMANAME, fkcols.REFOWNER, "
  781. + "  fkcols.REFTABLENAME, fkcols.REFCOLUMNNAME, fkcols.RULE "
  782. + "FROM " + "  FOREIGNKEYS as fk, "
  783. + "  FOREIGNKEYCOLUMNS as fkcols " + "WHERE "
  784. + "  fk.SCHEMANAME=? AND fk.TABLENAME=? "
  785. + "  AND fk.SCHEMANAME = fkcols.SCHEMANAME "
  786. + "  AND fk.TABLENAME = fkcols.TABLENAME "
  787. + "  AND fk.FKEYNAME = fkcols.FKEYNAME " + "ORDER BY "
  788. + "  FKEYNAME ASC";
  790. protected void reverseEngineerTableFKs(Connection conn, Catalog catalog,
  791. Schema schema, Table table) {
  793. String tableFKSelect = "";
  795. try {
  796. Grt.getInstance().addMsg("Fetching FK information.");
  797. tableFKSelect = (this.useRealSchema(conn)) ? tableFKSelect76
  798. : tableFKSelect75;
  799. Grt.getInstance().addMsgDetail(tableFKSelect);
  801. PreparedStatement stmt = conn.prepareStatement(tableFKSelect);
  802. stmt.setString(1, schema.getName());
  803. stmt.setString(2, table.getName());
  805. ResultSet rset = stmt.executeQuery();
  807. String fkName = "";
  808. ForeignKey foreignKey = null;
  810. while (rset.next()) {
  811. String newFkName = rset.getString("FKEYNAME");
  813. if (fkName.compareTo(newFkName) != 0) {
  814. if (foreignKey != null)
  815. table.getForeignKeys().add(foreignKey);
  817. foreignKey = new ForeignKey(table);
  819. foreignKey.setName(newFkName);
  821. foreignKey.setCreateDate(rset.getString("CREATEDATE"));
  822. foreignKey.setCreateTime(rset.getString("CREATETIME"));
  823. foreignKey.setDeferability(0);
  825. foreignKey.setDeleteRule(rset.getString("RULE")
  826. .substring(7));
  828. if (this.useRealSchema(conn)) {
  829. foreignKey.setReferedTableSchemaName(rset
  830. .getString("REFSCHEMANAME"));
  831. } else {
  832. foreignKey.setReferedTableSchemaName(rset
  833. .getString("REFOWNER"));
  834. }
  835. foreignKey.setReferedTableName(rset
  836. .getString("REFTABLENAME"));
  837. }
  839. foreignKey.getReferedColumnNames().add(
  840. rset.getString("REFCOLUMNNAME"));
  842. // find reference table column
  843. String colName = rset.getString("REFCOLUMNNAME");
  844. for (int j = 0; j < table.getColumns().size(); j++) {
  845. Column column = (Column) (table.getColumns().get(j));
  847. if (column.getName().compareTo(colName) == 0)
  848. foreignKey.getColumns().add(column);
  849. }
  850. }
  852. if (foreignKey != null)
  853. table.getForeignKeys().add(foreignKey);
  855. stmt.close();
  856. } catch (Exception e) {
  857. Grt.getInstance().addErr(e.getMessage());
  858. }
  859. }
  861. private static String tableTriggerSelect75 = "SELECT * FROM TRIGGERS WHERE "
  862. + "OWNER=? AND TABLENAME=? ORDER BY TRIGGERNAME ASC";
  864. private static String tableTriggerSelect76 = "SELECT * FROM TRIGGERS WHERE "
  865. + "SCHEMANAME=? AND TABLENAME=? ORDER BY TRIGGERNAME ASC";
  867. protected void reverseEngineerTableTriggers(Connection conn,
  868. Catalog catalog, Schema schema, Table table) {
  870. String tableTriggerSelect = "";
  871. String triggerStatements = "";
  873. try {
  874. Grt.getInstance().addMsg("Fetching FK information.");
  875. tableTriggerSelect = (this.useRealSchema(conn)) ? tableTriggerSelect76
  876. : tableTriggerSelect75;
  877. Grt.getInstance().addMsgDetail(tableTriggerSelect);
  879. PreparedStatement stmt = conn.prepareStatement(tableTriggerSelect);
  880. stmt.setString(1, schema.getName());
  881. stmt.setString(2, table.getName());
  883. ResultSet rset = stmt.executeQuery();
  885. while (rset.next()) {
  886. Trigger trigger = new Trigger(table);
  888. trigger.setName(rset.getString("TRIGGERNAME"));
  889. trigger.setOldName(trigger.getName());
  891. trigger.setComment(rset.getString("COMMENT"));
  892. trigger.setCreateDate(rset.getString("CREATEDATE"));
  893. trigger.setCreateTime(rset.getString("CREATETIME"));
  894. trigger.setDefinition(rset.getString("DEFINITION"));
  895. trigger.setTiming("AFTER");
  896. trigger.setOrder(0);
  897. trigger.setEnabled(1);
  899. if (rset.getString("INSERT").equalsIgnoreCase("YES")) {
  900. trigger.setEvent("INSERT");
  901. } else if (rset.getString("UPDATE").equalsIgnoreCase("YES")) {
  902. trigger.setEvent("UPDATE");
  903. } else if (rset.getString("DELETE").equalsIgnoreCase("YES")) {
  904. trigger.setEvent("DELETE");
  905. }
  907. triggerStatements = trigger.getDefinition().trim();
  908. triggerStatements = triggerStatements.substring(
  909. triggerStatements.indexOf("(") + 1, triggerStatements
  910. .lastIndexOf(")") - 1);
  911. trigger.setStatement(triggerStatements.trim());
  913. table.getTriggers().add(trigger);
  914. }
  916. stmt.close();
  917. } catch (Exception e) {
  918. Grt.getInstance().addErr(e.getMessage());
  919. }
  920. }
  922. private static String viewSelect75 = "SELECT " + "  v.*, vd.DEFINITION "
  923. + "FROM " + "  VIEWS AS v, " + "  VIEWDEFS AS vd " + "WHERE "
  924. + "  v.OWNER=? " + "  AND v.OWNER = vd.OWNER "
  925. + "  AND v.VIEWNAME = vd.VIEWNAME " + "  AND v.TYPE='VIEW'"
  926. + "ORDER BY " + "  VIEWNAME ASC";
  928. private static String viewSelect76 = "SELECT " + "  v.*, vd.DEFINITION "
  929. + "FROM " + "  VIEWS AS v, " + "  VIEWDEFS AS vd " + "WHERE "
  930. + "  v.SCHEMANAME=? " + "  AND v.SCHEMANAME = vd.SCHEMANAME "
  931. + "  AND v.VIEWNAME = vd.VIEWNAME " + "  AND v.TYPE='VIEW' "
  932. + "ORDER BY " + "  VIEWNAME ASC";
  934. protected void reverseEngineerViews(Connection conn, Catalog catalog,
  935. Schema schema) throws Exception {
  937. String viewSelect = "";
  939. viewSelect = (this.useRealSchema(conn)) ? viewSelect76 : viewSelect75;
  941. Grt.getInstance().addMsg(
  942. "Fetch all views of the schema " + schema.getName() + ".");
  943. Grt.getInstance().addMsgDetail(viewSelect);
  944. Grt.getInstance().flushMessages();
  946. PreparedStatement stmt = conn.prepareStatement(viewSelect);
  947. stmt.setString(1, schema.getName());
  949. ResultSet rset = stmt.executeQuery();
  951. while (rset.next()) {
  952. // Create new view
  953. View view = new View(schema);
  954. schema.getViews().add(view);
  956. view.setName(rset.getString("VIEWNAME"));
  957. Grt.getInstance().addMsg("Processing view " + view.getName() + ".");
  959. view.setAlterDate(rset.getString("ALTERDATE"));
  960. view.setAlterTime(rset.getString("ALTERTIME"));
  961. view.setComment(rset.getString("COMMENT"));
  962. view.setCreateDate(rset.getString("CREATEDATE"));
  963. view.setCreateTime(rset.getString("CREATETIME"));
  965. if (rset.getString("COMPLEX").compareToIgnoreCase("YES") == 0) {
  966. view.setIsReadOnly(1);
  967. } else {
  968. view.setIsReadOnly(0);
  969. }
  971. view.setPrivileges(rset.getString("PRIVILEGES"));
  972. view.setQueryExpression(rset.getString("DEFINITION"));
  973. view.setUnloaded(rset.getString("UNLOADED"));
  974. view.setUpdStatDate(rset.getString("UPDSTATDATE"));
  975. view.setUpdStatTime(rset.getString("UPDSTATTIME"));
  977. if (rset.getString("WITHCHECKOPTION").compareToIgnoreCase("YES") == 0) {
  978. view.setWithCheckCondition(1);
  979. } else {
  980. view.setWithCheckCondition(0);
  981. }
  983. }
  985. stmt.close();
  987. Grt.getInstance().addMsg("Views fetched.");
  988. }
  990. private static String ProcedureSelect = "SELECT "
  991. + "  DBPROCNAME AS PROCNAME, CREATEDATE, CREATETIME, "
  992. + "  OWNER, COMMENT, DEFINITION " + "FROM " + "  DBPROCEDURES "
  993. + "WHERE " + "  PACKAGE IS NULL " + "  AND EXECUTION_KIND IS NULL "
  994. + "  AND LANGUAGE = 'SPL' ";
  996. private static String FunctionSelect = "SELECT "
  997. + "  FUNCTIONNAME AS PROCNAME, CREATEDATE, CREATETIME, "
  998. + "  OWNER, COMMENT, DEFINITION " + "FROM " + "  FUNCTIONS "
  999. + "WHERE ";
  1001. private static String ProcedureCountSelect = "SELECT "
  1002. + "COUNT(*) AS NUM_PROCEDURES FROM DBPROCEDURES "
  1003. + "WHERE PACKAGE IS NULL AND EXECUTION_KIND IS NULL AND LANGUAGE = 'SPL' ";
  1005. private static String FunctionCountSelect = "SELECT "
  1006. + "COUNT(*) AS NUM_FUNCTIONS FROM FUNCTIONS WHERE ";
  1008. protected int reverseEngineerProcedures(Connection conn, Catalog catalog,
  1009. Schema schema) throws Exception {
  1010. int spCount = 0;
  1011. int currentSpNumber = 0;
  1012. String procedureSelect = "";
  1013. String procedureCountSelect = "";
  1015. if (this.useRealSchema(conn)) {
  1016. procedureSelect = ProcedureSelect + "AND SCHEMANAME=?";
  1017. procedureCountSelect = ProcedureCountSelect + "AND SCHEMANAME=?";
  1018. } else {
  1019. procedureSelect = ProcedureSelect + "AND OWNER=?";
  1020. procedureCountSelect = ProcedureCountSelect + "AND OWNER=?";
  1021. }
  1022. procedureSelect += " ORDER BY PROCNAME ASC";
  1024. Grt.getInstance().addMsg(
  1025. "Fetch count of stored procedures of the schema "
  1026. + schema.getName() + ".");
  1027. Grt.getInstance().addMsgDetail(procedureCountSelect);
  1029. try {
  1030. PreparedStatement stmt = conn
  1031. .prepareStatement(procedureCountSelect);
  1032. stmt.setString(1, schema.getName());
  1033. ResultSet rset = stmt.executeQuery();
  1034. if (rset.next()) {
  1035. spCount = rset.getInt("NUM_PROCEDURES");
  1036. }
  1038. Grt.getInstance().addMsg(
  1039. "Fetching " + spCount
  1040. + " stored procedure(s) of the schema "
  1041. + schema.getName() + ".");
  1042. Grt.getInstance().addMsgDetail(procedureSelect);
  1043. Grt.getInstance().flushMessages();
  1045. stmt = conn.prepareStatement(procedureSelect);
  1046. stmt.setString(1, schema.getName());
  1048. rset = stmt.executeQuery();
  1049. while (rset.next()) {
  1051. Routine proc = new Routine(schema);
  1052. schema.getRoutines().add(proc);
  1054. proc.setName(rset.getString("PROCNAME"));
  1056. currentSpNumber++;
  1058. Grt.getInstance().addProgress(
  1059. "Processing procedure " + proc.getName() + ".",
  1060. (currentSpNumber * 100) / spCount);
  1061. if (Grt.getInstance().flushMessages() != 0) {
  1062. Grt.getInstance().addMsg("Migration canceled by user.");
  1063. return 1;
  1064. }
  1066. Grt.getInstance().addMsg(
  1067. "Processing procedure " + proc.getName() + ".");
  1069. proc.setComment(rset.getString("COMMENT"));
  1070. proc.setRoutineCode(rset.getString("DEFINITION"));
  1071. proc.setRoutineType("PROCEUDRE");
  1072. proc.setCreateDate(rset.getString("CREATEDATE"));
  1073. proc.setCreateTime(rset.getString("CREATETIME"));
  1074. }
  1075. stmt.close();
  1077. Grt.getInstance().addMsg("Stored procedures fetched.");
  1079. if (this.useRealSchema(conn)) {
  1081. String functionSelect = FunctionSelect
  1082. + "SCHEMANAME=? ORDER BY PROCNAME ASC";
  1083. String functionCountSelect = FunctionCountSelect
  1084. + "SCHEMANAME=?";
  1086. stmt = conn.prepareStatement(functionCountSelect);
  1087. stmt.setString(1, schema.getName());
  1088. rset = stmt.executeQuery();
  1089. if (rset.next()) {
  1090. spCount = rset.getInt("NUM_FUNCTIONS");
  1091. }
  1093. Grt.getInstance().addMsg(
  1094. "Fetching " + spCount
  1095. + " stored functions(s) of the schema "
  1096. + schema.getName() + ".");
  1097. Grt.getInstance().addMsgDetail(functionSelect);
  1098. Grt.getInstance().flushMessages();
  1100. stmt = conn.prepareStatement(functionSelect);
  1101. stmt.setString(1, schema.getName());
  1103. rset = stmt.executeQuery();
  1104. while (rset.next()) {
  1106. Routine proc = new Routine(schema);
  1107. schema.getRoutines().add(proc);
  1109. proc.setName(rset.getString("PROCNAME"));
  1111. currentSpNumber++;
  1113. Grt.getInstance().addProgress(
  1114. "Processing stored function " + proc.getName()
  1115. + ".", (currentSpNumber * 100) / spCount);
  1116. if (Grt.getInstance().flushMessages() != 0) {
  1117. Grt.getInstance().addMsg("Migration canceled by user.");
  1118. return 1;
  1119. }
  1121. Grt.getInstance().addMsg(
  1122. "Processing function " + proc.getName() + ".");
  1124. proc.setComment(rset.getString("COMMENT"));
  1125. proc.setRoutineCode(rset.getString("DEFINITION"));
  1126. proc.setRoutineType("PROCEUDRE");
  1127. proc.setCreateDate(rset.getString("CREATEDATE"));
  1128. proc.setCreateTime(rset.getString("CREATETIME"));
  1129. }
  1130. stmt.close();
  1132. Grt.getInstance().addMsg("Stored functions fetched.");
  1133. }
  1135. Grt.getInstance().addProgress("", -1);
  1137. } catch (Exception e) {
  1138. Grt
  1139. .getInstance()
  1140. .addMsg(
  1141. "Stored procedures and stored functions cannot be fetched.");
  1142. Grt.getInstance().addMsgDetail(e.getMessage());
  1143. }
  1145. return 0;
  1146. }
  1148. private static String sequencesCountSelect76 = "SELECT COUNT(*) AS NUM_SEQUENCES "
  1149. + "FROM SEQUENCES WHERE SCHEMANAME=?";
  1151. private static String sequencesSelect76 = "SELECT * FROM SEQUENCES "
  1152. + "WHERE SCHEMANAME=? ORDER BY SEQUENCE_NAME ASC";
  1154. private static String sequencesCountSelect75 = "SELECT COUNT(*) AS NUM_SEQUENCES "
  1155. + "FROM SEQUENCES WHERE OWNER=?";
  1157. private static String sequencesSelect75 = "SELECT * FROM SEQUENCES "
  1158. + "WHERE OWNER=?";
  1160. protected int reverseEngineerSequences(Connection conn, Catalog catalog,
  1161. Schema schema) throws Exception {
  1162. int sequencesCount = 0;
  1163. int currentSequenceNumber = 0;
  1164. String sequencesSelect = "";
  1165. String sequencesCountSelect = "";
  1167. if (this.useRealSchema(conn)) {
  1168. sequencesSelect = sequencesSelect76;
  1169. sequencesCountSelect = sequencesCountSelect76;
  1170. } else {
  1171. sequencesSelect = sequencesSelect75;
  1172. sequencesCountSelect = sequencesCountSelect75;
  1173. }
  1175. Grt.getInstance().addMsg(
  1176. "Fetch the number sequences of the schema " + schema.getName()
  1177. + ".");
  1178. Grt.getInstance().addMsgDetail(sequencesCountSelect);
  1180. try {
  1181. PreparedStatement stmt = conn
  1182. .prepareStatement(sequencesCountSelect);
  1183. stmt.setString(1, schema.getName());
  1185. ResultSet rset = stmt.executeQuery();
  1187. if (rset.next()) {
  1188. sequencesCount = rset.getInt("NUM_SEQUENCES");
  1189. }
  1191. Grt.getInstance().addMsg(
  1192. "Fetch " + sequencesCount + " sequence(s) of the schema "
  1193. + schema.getName() + ".");
  1194. Grt.getInstance().addMsgDetail(sequencesSelect);
  1195. Grt.getInstance().flushMessages();
  1197. stmt = conn.prepareStatement(sequencesSelect);
  1198. stmt.setString(1, schema.getName());
  1200. rset = stmt.executeQuery();
  1202. while (rset.next()) {
  1204. Sequence seq = new Sequence(schema);
  1206. seq.setName(rset.getString("SEQUENCE_NAME"));
  1208. currentSequenceNumber++;
  1210. if (currentSequenceNumber % 5 == 0) {
  1211. Grt.getInstance().addProgress(
  1212. "Processing sequence " + seq.getName() + ".",
  1213. (currentSequenceNumber * 100) / sequencesCount);
  1214. Grt.getInstance().flushMessages();
  1215. }
  1217. seq.setCacheSize(rset.getString("CACHE_SIZE"));
  1218. seq.setComment(rset.getString("COMMENT"));
  1219. seq.setCreateDate(rset.getString("CREATEDATE"));
  1220. seq.setCreateTime(rset.getString("CREATETIME"));
  1222. if (rset.getString("CYCLE_FLAG").compareToIgnoreCase("Y") == 0) {
  1223. seq.setCycleFlag(1);
  1224. } else {
  1225. seq.setCycleFlag(0);
  1226. }
  1228. seq.setIncrementBy(rset.getString("INCREMENT_BY"));
  1229. seq.setLastNumber(rset.getString("LAST_NUMBER"));
  1230. seq.setMaxValue(rset.getString("MAX_VALUE"));
  1231. seq.setMinValue(rset.getString("MIN_VALUE"));
  1233. if (rset.getString("ORDER_FLAG").compareToIgnoreCase("Y") == 0) {
  1234. seq.setOrderFlag(1);
  1235. } else {
  1236. seq.setOrderFlag(0);
  1237. }
  1239. schema.getSequences().add(seq);
  1240. }
  1242. stmt.close();
  1244. Grt.getInstance().addMsg("Sequences fetched.");
  1246. Grt.getInstance().addProgress("", -1);
  1248. } catch (Exception e) {
  1249. Grt.getInstance().addMsg("Sequences could not be fetched.");
  1250. Grt.getInstance().addMsg(e.getMessage());
  1251. }
  1253. return 0;
  1254. }
  1256. private static String synonymsSelect76 = "SELECT * FROM SYNONYMS "
  1257. + "WHERE TABLESCHEMANAME=? ORDER BY TABLENAME ASC";
  1259. private static String synonymsSelect75 = "SELECT * FROM SYNONYMS "
  1260. + "WHERE TABLEOWNER=? ORDER BY TABLENAME ASC";
  1262. /**
  1263.  * Creates a list of table synonyms
  1264.  * 
  1265.  * @param conn
  1266.  * @param catalog
  1267.  * @param schema
  1268.  * @return int
  1269.  * @throws Exception
  1270.  */
  1271. protected int reverseEngineerSynonyms(Connection conn, Catalog catalog,
  1272. Schema schema) throws Exception {
  1274. String synonymsSelect = "";
  1275. synonymsSelect = (this.useRealSchema(conn)) ? synonymsSelect76
  1276. : synonymsSelect75;
  1278. Grt.getInstance().addMsg(
  1279. "Fetch all table synonyms of the schema " + schema.getName()
  1280. + ".");
  1281. Grt.getInstance().addMsgDetail(synonymsSelect);
  1282. Grt.getInstance().flushMessages();
  1284. PreparedStatement stmt = conn.prepareStatement(synonymsSelect);
  1285. stmt.setString(1, schema.getName());
  1287. ResultSet rset = stmt.executeQuery();
  1289. while (rset.next()) {
  1291. Synonym syn = new Synonym(schema);
  1292. schema.getSynonyms().add(syn);
  1294. syn.setName(rset.getString("SYNONYMNAME"));
  1295. Grt.getInstance().addMsg(
  1296. "Processing synonym " + syn.getName() + ".");
  1298. syn.setComment(rset.getString("COMMENT"));
  1299. syn.setCreateDate(rset.getString("CREATEDATE"));
  1300. syn.setCreateTime(rset.getString("CREATETIME"));
  1302. if (rset.getString("PUBLIC").compareToIgnoreCase("YES") == 0) {
  1303. syn.setIsPublic(1);
  1304. } else {
  1305. syn.setIsPublic(0);
  1306. }
  1308. // TODO: this is a consequence of the query
  1309. // How do we handle system internal synonyms?
  1310. syn.setReferedSchemaName(schema.getName());
  1312. // find reference table column
  1313. String tableName = rset.getString("TABLENAME");
  1314. for (int i = 0; i < schema.getTables().size(); i++) {
  1315. Table table = (Table) (schema.getTables().get(i));
  1317. if (table.getName().compareTo(tableName) == 0) {
  1318. syn.setReferedObject(table);
  1319. }
  1320. }
  1321. }
  1323. stmt.close();
  1325. Grt.getInstance().addMsg("Synonyms fetched.");
  1327. return 0;
  1328. }
  1330. /**
  1331.  * Checks the MaxDB version and returns 1 if the version supports real SQL
  1332.  * schemas
  1333.  * 
  1334.  * @param conn
  1335.  * @return
  1336.  * @throws Exception
  1337.  */
  1338. protected boolean useRealSchema(Connection conn) throws Exception {
  1340. DatabaseMetaData metaData = conn.getMetaData();
  1342. return ((metaData.getDatabaseMajorVersion() >= 7) && (metaData
  1343. .getDatabaseMinorVersion() >= 6));
  1344. }
  1345. }