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

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

MySQL数据库

开发平台：

SQL

ReverseEngineeringGeneric.java：源码内容
  1. package com.mysql.grt.modules;
  3. import java.net.URLEncoder;
  4. import java.sql.*;
  5. import java.text.MessageFormat;
  6. import java.text.ParsePosition;
  7. import java.util.regex.*;
  9. import com.mysql.grt.*;
  10. import com.mysql.grt.db.*;
  11. import com.mysql.grt.db.mgmt.*;
  13. /**
  14.  * GRT Reverse Engineering Class using generic JDBC metadata functions
  15.  * 
  16.  * @author Mike
  17.  * @version 1.0, 11/26/04
  18.  * 
  19.  */
  20. public class ReverseEngineeringGeneric {
  22. /**
  23.  * Static function to return information about this class to the GRT
  24.  * environment
  25.  * 
  26.  * @return returns a GRT XML string containing the infos about this class
  27.  */
  28. public static String getModuleInfo() {
  29. return Grt.getModuleInfoXml(ReverseEngineeringGeneric.class, "");
  30. }
  32. public static String replace(String searchIn, String searchFor,
  33. String replaceWith) {
  34. if (searchIn == null) {
  35. return null;
  36. }
  37. if (searchFor == null || "".equals(searchFor)) {
  38. final String msg = "searchFor '" + searchFor + "' (searchIn = '"
  39. + searchIn + "') (replaceWith='" + replaceWith + "')";
  40. throw new IllegalArgumentException(msg);
  41. }
  43. StringBuffer buf = new StringBuffer(searchIn.length());
  44. final int searchForLength = searchFor.length();
  45. int begin = 0;
  46. int end = 0;
  47. while (true) {
  48. end = searchIn.indexOf(searchFor, begin);
  49. if (end == -1) {
  50. break;
  51. }
  52. buf.append(searchIn.substring(begin, end));
  53. buf.append(replaceWith);
  54. begin = end + searchForLength;
  55. }
  57. buf.append(searchIn.substring(begin));
  58. return buf.toString();
  59. }
  61. /**
  62.  * Protected function that establishes a connection to the database
  63.  * 
  64.  * @param dbConn
  65.  *            the Connection to connect to
  66.  * 
  67.  * @return returns a Connection on success
  68.  */
  69. protected static java.sql.Connection establishConnection(
  70. com.mysql.grt.db.mgmt.Connection dbConn) throws Exception {
  71. com.mysql.grt.db.mgmt.Driver driver = dbConn.getDriver();
  73. if (!JdbcDriver.class.isInstance(driver))
  74. throw new Exception("The submitted driver is not a JDBC driver.");
  76. Grt.getInstance().addMsg("Initializing JDBC driver ... ");
  77. Grt.getInstance().addMsgDetail("Driver class " + driver.getCaption());
  79. // get classname
  80. String driverClassName = ((JdbcDriver) driver).getClassName();
  81. // if there is no classname entry in the driver, take it from the params
  82. if (driverClassName.equals(""))
  83. driverClassName = dbConn.getParameterValues().get("classname");
  84. Class.forName(driverClassName).newInstance();
  86. // build connection string
  87. // first, check if the jdbcConnStr param is set
  88. String jdbcConnectionString = dbConn.getParameterValues().get(
  89. "jdbcConnStr");
  90. if ((jdbcConnectionString == null) || jdbcConnectionString.equals("")) {
  91. // if the param is not set, take build the connection string from
  92. // the template
  93. jdbcConnectionString = ((JdbcDriver) driver)
  94. .getConnectionStringTemplate();
  96. GrtStringHashMap paramValues = dbConn.getParameterValues();
  97. for (int i = 0; i < paramValues.getKeys().length; i++) {
  98. String key = paramValues.getKeys()[i];
  99. String value = paramValues.get(key);
  101. // if this is the MySQL JDBC driver, encode the value
  102. if (driverClassName.equals("com.mysql.jdbc.Driver"))
  103. value = URLEncoder.encode(value, "UTF-8");
  105. jdbcConnectionString = replace(jdbcConnectionString, "%"
  106. + key + "%", value);
  108. /*String value = paramValues.get(key).replaceAll("\\",
  109. "\\\\");
  111. if (!value.equals("")) {
  112. // if this is the MySQL JDBC driver, encode the value
  113. if (driverClassName.equals("com.mysql.jdbc.Driver"))
  114. value = URLEncoder.encode(value, "UTF-8");
  116. jdbcConnectionString = jdbcConnectionString.replaceAll("%"
  117. + key + "%", value);
  119. } else
  120. jdbcConnectionString = Grt.replace(jdbcConnectionString,
  121. "%" + key + "%", "");*/
  122. }
  123. }
  125. Grt.getInstance().addMsg("Opening connection ... ");
  126. Grt.getInstance().addMsgDetail("Connection " + jdbcConnectionString);
  127. Grt.getInstance().flushMessages();
  129. // get the connection
  130. java.sql.Connection conn = null;
  132. // if an explicit username is given, use it
  133. String explicitUsername = dbConn.getParameterValues().get(
  134. "explicit_username");
  135. String explicitPassword = dbConn.getParameterValues().get(
  136. "explicit_password");
  137. if (explicitUsername != null && !explicitUsername.equalsIgnoreCase("")) {
  138. conn = DriverManager.getConnection(jdbcConnectionString,
  139. explicitUsername, explicitPassword);
  140. } else
  141. conn = DriverManager.getConnection(jdbcConnectionString);
  143. return conn;
  144. }
  146. /**
  147.  * Get version info of the RDBMS
  148.  * 
  149.  * This function connects to the target database system and retrieves the
  150.  * version information
  151.  * 
  152.  * @param dbConn
  153.  *            a Connection
  154.  * @return returns the version information
  155.  */
  157. public static Version getVersion(com.mysql.grt.db.mgmt.Connection dbConn)
  158. throws Exception {
  160. // connect to the database
  161. java.sql.Connection conn = establishConnection(dbConn);
  163. Grt.getInstance().addMsg("Getting version information ... ");
  165. Version versionInfo = new Version(null);
  167. String skipVersionDetection = dbConn.getParameterValues().get(
  168. "skipVersionDetection");
  170. if ((skipVersionDetection == null) || !skipVersionDetection.equals("1")) {
  171. try {
  172. DatabaseMetaData metaData = conn.getMetaData();
  174. com.mysql.grt.db.mgmt.Driver driver = dbConn.getDriver();
  176. if (!JdbcDriver.class.isInstance(driver))
  177. throw new Exception(
  178. "The submitted driver is not a JDBC driver.");
  180. Grt.getInstance().addMsg("Initializing JDBC driver ... ");
  181. Grt.getInstance().addMsgDetail(
  182. "Driver class " + driver.getCaption());
  184. versionInfo.setName(metaData.getDatabaseProductVersion());
  185. versionInfo.setMajor(metaData.getDatabaseMajorVersion());
  186. versionInfo.setMinor(metaData.getDatabaseMinorVersion());
  188. // get the release number
  189. MessageFormat mf = new MessageFormat(
  190. "{0}.{0}.{0,number,integer}{1}");
  191. Object[] objs = mf.parse(metaData.getDatabaseProductVersion(),
  192. new ParsePosition(0));
  193. if (objs != null)
  194. versionInfo
  195. .setRelease(Integer.parseInt(objs[0].toString()));
  196. } catch (Throwable t) {
  197. // ignore exceptions if the driver does not support the version
  198. // functions and try to recover from getDatabaseProductVersion()
  199. // we found no other way to prevent the AbstractMethodError
  201. if (versionInfo.getName() != null
  202. && !versionInfo.getName().equalsIgnoreCase("")) {
  203. Pattern p = Pattern.compile(
  204. ".*?(\d+)\.(\d+)\.(\d+).*", Pattern.DOTALL);
  205. Matcher m = p.matcher(versionInfo.getName());
  206. if (m.matches()) {
  207. versionInfo.setMajor(Integer.parseInt(m.group(1)));
  208. versionInfo.setMinor(Integer.parseInt(m.group(2)));
  209. versionInfo.setRelease(Integer.parseInt(m.group(3)));
  210. }
  211. }
  212. }
  213. }
  215. return versionInfo;
  216. }
  218. /**
  219.  * Returns a list of all schemata from the given JDBC connection
  220.  * 
  221.  * @param jdbcDriver
  222.  *            the class name of the JDBC driver
  223.  * @param jdbcConnectionString
  224.  *            a JDBC connection string
  225.  * @return returns a GRT XML string containing a list of schemata names
  226.  */
  227. public static GrtStringList getSchemata(
  228. com.mysql.grt.db.mgmt.Connection dbConn) throws Exception {
  230. java.sql.Connection conn = establishConnection(dbConn);
  232. Grt.getInstance().addMsg("Fetching schemata list.");
  234. GrtStringList schemataList = new GrtStringList();
  236. ResultSet rset = conn.getMetaData().getSchemas();
  237. while (rset.next()) {
  238. String schemaName = rset.getString("TABLE_SCHEM");
  240. if (schemaName != null)
  241. schemataList.add(schemaName);
  242. }
  243. rset.close();
  244. conn.close();
  246. if (schemataList.size() == 0) {
  247. schemataList.add("DEFAULT");
  248. GrtHashMap dataBulkTransferParams = (GrtHashMap) Grt.getInstance()
  249. .getGrtGlobalAsObject("/migration/dataBulkTransferParams");
  251. dataBulkTransferParams.addObject("excludeSourceSchemaName", "yes");
  252. }
  254. Grt.getInstance().addMsg("Return schemata list.");
  255. return schemataList;
  256. }
  258. /**
  259.  * Does the reverse engineering of the given schematas over the JDBC
  260.  * connection and returns the GRT objects
  261.  * 
  262.  * @param jdbcDriver
  263.  *            the class name of the JDBC driver
  264.  * @param jdbcConnectionString
  265.  *            a JDBC connection string
  266.  * @param schemataList
  267.  *            list of schematas to be reverse engineered
  268.  * @return returns a GRT XML string containing a the reverse engineered
  269.  *         objects
  270.  */
  271. public static Catalog reverseEngineer(
  272. com.mysql.grt.db.mgmt.Connection dbConn, GrtStringList schemataList)
  273. throws Exception {
  275. boolean reverseEngineerOnlyTableObjects = (Grt.getInstance()
  276. .getGrtGlobalAsInt(
  277. "/migration/applicationData/"
  278. + "reverseEngineerOnlyTableObjects") == 1);
  280. ReverseEngineeringGeneric revEng = new ReverseEngineeringGeneric();
  282. java.sql.Connection conn = establishConnection(dbConn);
  284. Catalog catalog = new Catalog(null);
  285. catalog.setName("GenericCatalog");
  287. catalog.setVersion(getVersion(dbConn));
  289. Grt.getInstance().addMsg("Build simple datatypes.");
  290. revEng.buildSimpleDatatypes(conn, catalog);
  292. // If an empty list was given, use a list with an empty string instead
  293. if (schemataList.size() == 0)
  294. schemataList.add("");
  296. for (int i = 0; i < schemataList.size(); i++) {
  297. Schema schema = new Schema(catalog);
  298. schema.setName((String) (schemataList.get(i)));
  299. catalog.getSchemata().add(schema);
  301. // Get Tables
  302. revEng.reverseEngineerTables(conn, catalog, schema);
  304. if (!reverseEngineerOnlyTableObjects) {
  305. // Get Views
  306. revEng.reverseEngineerViews(conn, catalog, schema);
  308. // Get SPs
  309. revEng.reverseEngineerProcedures(conn, catalog, schema);
  310. }
  311. }
  313. // make sure the Fks use real references instead of
  314. // text names where possible
  315. revEng.reverseEngineerUpdateFkReferences(catalog);
  317. conn.close();
  319. return catalog;
  320. }
  322. protected void buildSimpleDatatypes(java.sql.Connection conn,
  323. Catalog catalog) throws Exception {
  325. GrtList simpleDatatypes = new GrtList(catalog);
  326. DatatypeGroup group = new DatatypeGroup(catalog);
  327. group.setName("Generic Datatype Group");
  328. group.setCaption("Generic Datatype Group");
  329. group
  330. .setDescription("A generic datatype group holding JDBC datatypes.");
  332. catalog.getCustomData().addObject("simpleDatatypes", simpleDatatypes);
  333. catalog.getCustomData().addObject("datatypeGroup", group);
  335. ResultSet rset = conn.getMetaData().getTypeInfo();
  336. while (rset.next()) {
  337. SimpleDatatype simpleType = new SimpleDatatype(catalog);
  338. simpleType.setGroup(group);
  340. catalog.getSimpleDatatypes().add(simpleType);
  342. simpleType.setName(rset.getString("TYPE_NAME"));
  344. long precision = rset.getLong("PRECISION");
  345. if (precision >= new Long("4294967296").longValue())
  346. precision = precision / 1000000 * -1;
  347. simpleType.setNumericPrecision(new Long(precision).intValue());
  349. simpleType.setNumericPrecisionRadix(rset.getInt("NUM_PREC_RADIX"));
  350. simpleType.setNumericScale(rset.getInt("MAXIMUM_SCALE"));
  352. simpleDatatypes.addObject(simpleType);
  353. }
  354. rset.close();
  355. }
  357. protected void reverseEngineerTables(java.sql.Connection conn,
  358. Catalog catalog, Schema schema) throws Exception {
  360. Grt.getInstance().addMsg("Fetch all tables of given schemata.");
  362. ResultSet rset = conn.getMetaData().getTables(null, schema.getName(),
  363. null, new String[] { "TABLE" });
  364. while (rset.next()) {
  365. // Create new table
  366. Table table = new Table(schema);
  367. schema.getTables().add(table);
  369. table.setName(rset.getString("TABLE_NAME"));
  371. reverseEngineerTableColumns(conn, catalog, schema, table);
  373. reverseEngineerTablePK(conn, catalog, schema, table);
  375. reverseEngineerTableIndices(conn, catalog, schema, table);
  377. reverseEngineerTableFKs(conn, catalog, schema, table);
  378. }
  379. rset.close();
  380. }
  382. protected void reverseEngineerTableColumns(java.sql.Connection conn,
  383. Catalog catalog, Schema schema, Table table) {
  385. try {
  386. Grt.getInstance().addMsg(
  387. "Fetching column information of table " + table.getName()
  388. + ".");
  390. ResultSet rset = conn.getMetaData().getColumns(null,
  391. schema.getName(), table.getName(), null);
  393. boolean hasDefaultValueColumn = false;
  394. ResultSetMetaData rsmd = rset.getMetaData();
  395. for (int i = 1; i <= rsmd.getColumnCount(); i++)
  396. if (rsmd.getColumnName(i).equalsIgnoreCase("COLUMN_DEF"))
  397. hasDefaultValueColumn = true;
  399. while (rset.next()) {
  400. // create new column
  401. Column column = new Column(table);
  402. table.getColumns().add(column);
  404. column.setName(rset.getString("COLUMN_NAME"));
  405. column.setDatatypeName(rset.getString("TYPE_NAME"));
  407. // Get Simple Type
  408. int datatypeIndex = catalog.getSimpleDatatypes()
  409. .getIndexOfName(column.getDatatypeName());
  410. if (datatypeIndex > -1)
  411. column.setSimpleType(catalog.getSimpleDatatypes().get(
  412. datatypeIndex));
  414. column.setLength(rset.getInt("COLUMN_SIZE"));
  415. column.setPrecision(column.getLength());
  416. column.setScale(rset.getInt("DECIMAL_DIGITS"));
  418. // make sure precision is greater than scale
  419. if (column.getPrecision() < column.getScale()) {
  420. column.setPrecision(16);
  422. if (column.getPrecision() < column.getScale())
  423. column.setPrecision(column.getScale() + 1);
  424. }
  426. if (rset.getInt("NULLABLE") == java.sql.DatabaseMetaData.columnNullable)
  427. column.setIsNullable(1);
  428. else
  429. column.setIsNullable(0);
  431. // prevent VARCHAR(0) columns
  432. if (column.getDatatypeName().equalsIgnoreCase("VARCHAR")
  433. && column.getLength() == 0)
  434. column.setLength(255);
  436. if (hasDefaultValueColumn)
  437. column.setDefaultValue(rset.getString("COLUMN_DEF"));
  438. else
  439. column.setDefaultValueIsNull(1);
  440. }
  442. rset.close();
  443. } catch (Exception e) {
  444. Grt.getInstance().addErr(e.getMessage());
  445. }
  446. }
  448. protected void reverseEngineerTablePK(java.sql.Connection conn,
  449. Catalog catalog, Schema schema, Table table) {
  451. // String sql;
  453. try {
  454. Grt.getInstance().addMsg("Fetching primary key information.");
  456. ResultSet rset = conn.getMetaData().getPrimaryKeys(null, null,
  457. table.getName());
  459. Index primaryKey = null;
  460. String primaryKeyName = null;
  462. while (rset.next()) {
  463. if (primaryKey == null) {
  464. primaryKey = new Index(table);
  465. primaryKey.setName("PRIMARY");
  467. primaryKey.setIsPrimary(1);
  469. // add PK to indices
  470. table.getIndices().add(primaryKey);
  472. table.setPrimaryKey(primaryKey);
  473. }
  475. primaryKeyName = rset.getString("PK_NAME");
  477. IndexColumn indexColumn = new IndexColumn(primaryKey);
  478. indexColumn.setName(rset.getString("COLUMN_NAME"));
  479. indexColumn.setColumnLength(0);
  481. // find reference table column
  482. for (int j = 0; j < table.getColumns().size(); j++) {
  483. Column column = (Column) (table.getColumns().get(j));
  485. if (column.getName().compareToIgnoreCase(
  486. indexColumn.getName()) == 0) {
  487. indexColumn.setReferedColumn(column);
  489. // text and blob have to have a index column length
  490. if ((indexColumn.getColumnLength() == 0)
  491. && (column.getSimpleType().getGroup().getName()
  492. .equals("text") || column
  493. .getSimpleType().getGroup().getName()
  494. .equals("blob")))
  495. indexColumn.setColumnLength(10);
  497. break;
  498. }
  499. }
  501. primaryKey.getColumns().add(indexColumn);
  502. }
  504. // remove primary key from list of indices
  505. if (primaryKeyName != null) {
  506. for (int i = 0; i < table.getIndices().size(); i++) {
  507. String indexName = table.getIndices().get(i).getName();
  509. if (primaryKeyName.compareToIgnoreCase(indexName) == 0) {
  510. table.getIndices().remove(i);
  511. break;
  512. }
  513. }
  514. }
  515. } catch (Exception e) {
  516. Grt.getInstance().addErr(e.getMessage());
  517. }
  518. }
  520. protected void reverseEngineerTableIndices(java.sql.Connection conn,
  521. Catalog catalog, Schema schema, Table table) {
  522. try {
  523. Grt.getInstance().addMsg(
  524. "Fetching index information of table " + table.getName()
  525. + ".");
  527. String indexName = "";
  528. Index index = null;
  530. ResultSet rset = conn.getMetaData().getIndexInfo(null, null,
  531. table.getName(), false, true);
  532. while (rset.next()) {
  533. String newIndexName = rset.getString("INDEX_NAME");
  535. if (newIndexName == null)
  536. continue;
  538. if (!indexName.equalsIgnoreCase(newIndexName)) {
  539. if (index != null)
  540. table.getIndices().add(index);
  542. indexName = newIndexName;
  544. index = new Index(table);
  545. index.setName(indexName);
  547. if (rset.getBoolean("NON_UNIQUE"))
  548. index.setUnique(0);
  549. else
  550. index.setUnique(1);
  551. }
  553. IndexColumn indexColumn = new IndexColumn(index);
  554. indexColumn.setName(rset.getString("COLUMN_NAME"));
  555. indexColumn.setColumnLength(0);
  557. if (rset.getString("ASC_OR_DESC").compareToIgnoreCase("D") == 0)
  558. indexColumn.setDescend(1);
  559. else
  560. indexColumn.setDescend(0);
  562. // find reference table column
  563. for (int j = 0; j < table.getColumns().size(); j++) {
  564. Column column = (Column) (table.getColumns().get(j));
  566. if (column.getName().compareToIgnoreCase(
  567. indexColumn.getName()) == 0) {
  568. indexColumn.setReferedColumn(column);
  570. // text and blob have to have a index column length
  571. if ((indexColumn.getColumnLength() == 0)
  572. && (column.getSimpleType() != null)
  573. && (column.getSimpleType().getGroup() != null)
  574. && (column.getSimpleType().getGroup().getName()
  575. .equals("text") || column
  576. .getSimpleType().getGroup().getName()
  577. .equals("blob")))
  578. indexColumn.setColumnLength(10);
  580. break;
  581. }
  582. }
  584. index.getColumns().add(indexColumn);
  585. }
  587. if (index != null)
  588. table.getIndices().add(index);
  590. } catch (Exception e) {
  591. Grt.getInstance().addErr(e.getMessage());
  592. }
  593. }
  595. protected void reverseEngineerTableFKs(java.sql.Connection conn,
  596. Catalog catalog, Schema schema, Table table) {
  598. try {
  599. Grt.getInstance().addMsg("Fetching FK information.");
  601. ResultSet rset = conn.getMetaData().getImportedKeys(null, null,
  602. table.getName());
  604. String fkName = "";
  605. ForeignKey foreignKey = null;
  607. while (rset.next()) {
  608. String newFkName = rset.getString("FK_NAME");
  610. if (fkName.compareToIgnoreCase(newFkName) != 0) {
  611. if (foreignKey != null)
  612. table.getForeignKeys().add(foreignKey);
  614. fkName = newFkName;
  615. foreignKey = new ForeignKey(table);
  616. foreignKey.setName(fkName);
  618. foreignKey.setDeferability(rset.getInt("DEFERRABILITY"));
  620. switch (rset.getShort("DELETE_RULE")) {
  621. case DatabaseMetaData.importedKeyCascade:
  622. foreignKey.setDeleteRule("CASCADE");
  623. break;
  624. case DatabaseMetaData.importedKeyRestrict:
  625. foreignKey.setDeleteRule("RESTRICT");
  626. break;
  627. case DatabaseMetaData.importedKeySetNull:
  628. foreignKey.setDeleteRule("SET NULL");
  629. break;
  630. default:
  631. foreignKey.setDeleteRule("NO ACTION");
  632. break;
  633. }
  635. switch (rset.getShort("UPDATE_RULE")) {
  636. case DatabaseMetaData.importedKeyCascade:
  637. foreignKey.setUpdateRule("CASCADE");
  638. break;
  639. case DatabaseMetaData.importedKeyRestrict:
  640. foreignKey.setUpdateRule("RESTRICT");
  641. break;
  642. case DatabaseMetaData.importedKeySetNull:
  643. foreignKey.setUpdateRule("SET NULL");
  644. break;
  645. default:
  646. foreignKey.setUpdateRule("NO ACTION");
  647. break;
  648. }
  650. String fkSchemaName = rset.getString("PKTABLE_SCHEM");
  652. if (rset.wasNull())
  653. foreignKey.setReferedTableSchemaName(schema.getName());
  654. else
  655. foreignKey.setReferedTableSchemaName(fkSchemaName);
  657. foreignKey.setReferedTableName(rset
  658. .getString("PKTABLE_NAME"));
  659. }
  661. foreignKey.getReferedColumnNames().add(
  662. rset.getString("PKCOLUMN_NAME"));
  664. // find reference table column
  665. String colName = rset.getString("FKCOLUMN_NAME");
  666. boolean found = false;
  667. for (int j = 0; j < table.getColumns().size(); j++) {
  668. Column column = (Column) (table.getColumns().get(j));
  670. if (column.getName().compareToIgnoreCase(colName) == 0) {
  671. foreignKey.getColumns().add(column);
  672. found = true;
  673. break;
  674. }
  675. }
  677. if (!found)
  678. Grt.getInstance().addErr(
  679. "Column " + colName + " not found in table "
  680. + table.getName() + ".");
  681. }
  683. if (foreignKey != null)
  684. table.getForeignKeys().add(foreignKey);
  686. } catch (Exception e) {
  687. Grt.getInstance().addErr(e.getMessage());
  688. }
  689. }
  691. protected void reverseEngineerUpdateFkReferences(Catalog catalog) {
  692. SchemaList schemata = catalog.getSchemata();
  694. // do for all schemata
  695. for (int i = 0; i < schemata.size(); i++) {
  696. Schema schema = schemata.get(i);
  697. TableList tables = schema.getTables();
  699. // do for all tables
  700. for (int j = 0; j < tables.size(); j++) {
  701. ForeignKeyList fks = tables.get(j).getForeignKeys();
  703. // do for all foreign keys
  704. for (int k = 0; k < fks.size(); k++) {
  705. ForeignKey fk = fks.get(k);
  706. String refSchemaName = fk.getReferedTableSchemaName();
  707. Schema refSchema;
  709. // get the refered schema
  710. if ((refSchemaName != null) && (!refSchemaName.equals(""))
  711. && !refSchemaName.equals(schema.getName()))
  712. refSchema = schemata.getItemByName(refSchemaName);
  713. else
  714. refSchema = schema;
  716. if (refSchema != null) {
  717. String refTableName = fk.getReferedTableName();
  719. // get the refered table
  720. Table refTable = refSchema.getTables().getItemByName(
  721. refTableName);
  722. if (refTable != null) {
  723. GrtStringList refColNames = fk
  724. .getReferedColumnNames();
  725. ColumnList refTableCols = refTable.getColumns();
  727. ColumnList refCols = fk.getReferedColumns();
  728. if (refCols == null) {
  729. fk.setColumns(new ColumnList());
  730. refCols = fk.getReferedColumns();
  731. }
  733. // set the table reference in the fk
  734. fk.setReferedTable(refTable);
  736. for (int l = 0; l < refColNames.size(); l++) {
  737. Column refCol = refTableCols
  738. .getItemByName(refColNames.get(l));
  740. if (refCol != null) {
  741. // add column reference to the fk column
  742. // list
  743. fk.getReferedColumns().add(refCol);
  744. }
  745. }
  746. }
  747. }
  748. }
  749. }
  750. }
  751. }
  753. protected void reverseEngineerViews(java.sql.Connection conn,
  754. Catalog catalog, Schema schema) throws Exception {
  756. Grt.getInstance().addMsg("Fetch all views of the given schemata.");
  757. }
  759. protected void reverseEngineerProcedures(java.sql.Connection conn,
  760. Catalog catalog, Schema schema) throws Exception {
  762. Grt.getInstance().addMsg(
  763. "Fetch all stored procedures of the given schemata.");
  764. }
  765. }