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

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

MySQL数据库

开发平台：

SQL

MigrationMaxdb.java：源码内容
  1. package com.mysql.grt.modules;
  3. import com.mysql.grt.*;
  4. import com.mysql.grt.db.SimpleDatatypeList;
  5. import com.mysql.grt.db.migration.*;
  6. import com.mysql.grt.db.maxdb.*;
  8. /**
  9.  * GRT Migration Class for Maxdb 7.5/7.6
  10.  * 
  11.  * @author Mike
  12.  * @version 1.0, 01/11/05
  13.  * 
  14.  */
  15. public class MigrationMaxdb extends MigrationGeneric {
  17. /**
  18.  * Sequential number added to FK names to ensure their uniqueness
  19.  * 
  20.  */
  21. private int fkSeqNum = 0;
  23. /**
  24.  * Static function to return information about this class to the GRT
  25.  * environment
  26.  * 
  27.  * @return returns a GRT XML string containing the infos about this class
  28.  */
  29. public static String getModuleInfo() {
  30. return Grt.getModuleInfoXml(MigrationMaxdb.class, "MigrationGeneric");
  31. }
  33. /**
  34.  * Collects information about the migration methods to let the user choose
  35.  * which one to take
  36.  * 
  37.  * @return returns a Method with predefined migration parameters
  38.  */
  39. public static MethodList migrationMethods() {
  40. MethodList methods = MigrationGeneric.migrationMethods();
  42. // add methods to methodlist
  43. MigrationMaxdb mig = new MigrationMaxdb();
  44. methods.add(mig.getMigrateSchemaToMysqlInfo());
  45. methods.add(mig.getMigrateTableToMysqlInfo());
  46. methods.add(mig.getMigrateColumnToMysqlInfo());
  47. methods.add(mig.getMigrateForeignKeyToMysqlInfo());
  48. methods.add(mig.getMigrateViewToMysqlInfo());
  49. methods.add(mig.getMigrateRoutineToMysqlInfo());
  50. methods.add(mig.getMigrateSynonymToMysql());
  51. methods.add(mig.getMigrateTriggerToMysql());
  53. return methods;
  54. }
  56. /**
  57.  * Performs a migration based on a Migration object
  58.  * 
  59.  * @param migObj
  60.  *            migration object to migrate
  61.  * @param targetPackageName
  62.  *            name of the package that should be used to generate the target
  63.  *            objects, e.g. db.mysql
  64.  */
  65. public static void migrate(com.mysql.grt.db.migration.Migration migObj,
  66. com.mysql.grt.db.mgmt.Rdbms targetRdbms,
  67. com.mysql.grt.db.Version version) throws Exception {
  69. Grt.getInstance().addMsg("Starting MaxDB migration...");
  71. new MigrationMaxdb().migrateCatalog(migObj, targetRdbms, version);
  72. }
  74. /**
  75.  * Performs a data transfer from the given source catalog to the target
  76.  * catalog
  77.  * 
  78.  * @param sourceJdbcDriver
  79.  *            class name of the source jdbc driver
  80.  * @param sourceJdbcConnectionString
  81.  *            jdbc connection string to the source database
  82.  * @param sourceCatalog
  83.  *            the source catalog
  84.  * @param targetJdbcDriver
  85.  *            class name of the target jdbc driver
  86.  * @param targetJdbcConnectionString
  87.  *            jdbc connection string to the target database
  88.  * @param targetCatalog
  89.  *            the target catalog
  90.  * @param params
  91.  *            parameters that define how the migration is performed
  92.  */
  93. public static void dataBulkTransfer(
  94. com.mysql.grt.db.mgmt.Connection sourceDbConn,
  95. Catalog sourceCatalog,
  96. com.mysql.grt.db.mgmt.Connection targetDbConn,
  97. com.mysql.grt.db.Catalog targetCatalog, GrtStringHashMap params,
  98. com.mysql.grt.base.ObjectLogList logList) throws Exception {
  100. new MigrationMaxdb().doDataBulkTransfer(sourceDbConn, sourceCatalog,
  101. targetDbConn, targetCatalog, params, logList);
  102. }
  104. /**
  105.  * migrates the name of an identifier
  106.  * 
  107.  * @param name
  108.  *            the source name of the identifier
  109.  * @return the migrated identifier name
  110.  */
  111. protected String migrateIdentifier(String name) {
  112. return name.toLowerCase();
  113. }
  115. /**
  116.  * migrates the sourceSchema and stores the targetCatalog in the global
  117.  * migration object
  118.  * 
  119.  * @param migObj
  120.  *            migration object to migrate
  121.  * @param targetPackageName
  122.  *            name of the package that should be used to generate the target
  123.  *            objects, e.g. db.mysql
  124.  * @param sourceSchema
  125.  *            the source schema that should be migrated
  126.  * 
  127.  */
  128. protected com.mysql.grt.db.mysql.Schema migrateSchemaToMysql(
  129. com.mysql.grt.db.migration.Migration migObj, Schema sourceSchema,
  130. GrtStringHashMap migrationParams, GrtObject parent) {
  132. // call super migrate function to do basic migration
  133. com.mysql.grt.db.mysql.Schema targetSchema = super
  134. .migrateSchemaToMysql(migObj, sourceSchema, migrationParams,
  135. parent);
  137. for (int i = 0; i < sourceSchema.getSynonyms().size(); i++) {
  138. Synonym sourceSynonym = (Synonym)sourceSchema.getSynonyms().get(i);
  140. Grt.getInstance().addProgress(
  141. "Migrating synonym " + sourceSynonym.getName(),
  142. (i * 100) / sourceSchema.getSynonyms().size());
  143. if (Grt.getInstance().flushMessages() != 0) {
  144. Grt.getInstance().addMsg("Migration canceled by user.");
  145. return targetSchema;
  146. }
  148. com.mysql.grt.db.mysql.Synonym targetSynonym = (com.mysql.grt.db.mysql.Synonym) migUtils.migrateObject(this, migObj,
  149. sourceSynonym, targetSchema);
  151. if (targetSynonym != null)
  152. targetSchema.getSynonyms().add(targetSynonym);
  153. }
  155. return targetSchema;
  156. }
  158. /**
  159.  * Migrates an MaxDB table to a MySQL table
  160.  * 
  161.  * @param sourceTable
  162.  *            the object to migrate
  163.  * @param migrationParams
  164.  *            parameters used to define the target object
  165.  * 
  166.  * @return returns MySQL table object
  167.  */
  168. protected com.mysql.grt.db.mysql.Table migrateTableToMysql(
  169. com.mysql.grt.db.migration.Migration migObj, Table sourceTable,
  170. GrtStringHashMap migrationParams, GrtObject parent) {
  172. String comment = "";
  174. // call migration method from the super class
  175. com.mysql.grt.db.mysql.Table targetTable;
  176. targetTable = super.migrateTableToMysql(migObj, sourceTable,
  177. migrationParams, parent);
  179. // MaxDB specific things
  181. // MaxDB has some table stats and some flags, that can't be migrated
  182. // noFixedLenghtColumn() might go into ROWFORMAT, but InnoDB uses
  183. // COMPACT anyway.
  184. if (sourceTable.getComment() != null) {
  185. comment += " Comment: " + sourceTable.getComment();
  186. }
  187. comment += " Hints: ";
  188. if (sourceTable.getPrivileges() != null)
  189. comment += " Privileges: " + sourceTable.getPrivileges();
  191. comment += " Created: " + sourceTable.getCreateDate() + " / "
  192. + sourceTable.getCreateTime();
  193. comment += " Altered: " + sourceTable.getAlterDate() + " / "
  194. + sourceTable.getAlterTime();
  196. if (sourceTable.getUpdStatDate() != null)
  197. comment += " Statistics: " + sourceTable.getUpdStatDate() + " / "
  198. + sourceTable.getUpdStatTime();
  200. if (sourceTable.getSample() != null)
  201. comment += " Sample: " + sourceTable.getSample();
  203. if (sourceTable.getArchive() != null)
  204. comment += " Archive: " + sourceTable.getArchive();
  206. if (sourceTable.getVariableColumns() != null)
  207. comment += " Variable columns: " + sourceTable.getVariableColumns();
  209. if (sourceTable.getTableid() != null)
  210. comment += " TableId: " + sourceTable.getTableid();
  212. if (sourceTable.getNoFixedLengthColumn() > 0)
  213. comment += " No fixed length column "
  214. + sourceTable.getNoFixedLengthColumn();
  216. targetTable.setComment(comment);
  218. // Trigger
  219. for (int i = 0; i < sourceTable.getTriggers().size(); i++) {
  220. Trigger sourceTrigger = (Trigger)sourceTable.getTriggers().get(i);
  222. com.mysql.grt.db.mysql.Trigger targetTrigger = (com.mysql.grt.db.mysql.Trigger) migUtils.migrateObject(this, migObj,
  223. sourceTrigger, targetTable);
  225. if (targetTrigger != null)
  226. targetTable.getTriggers().add(targetTrigger);
  227. }
  229. // return new created, migrated object
  230. return targetTable;
  231. }
  233. /**
  234.  * Migrates a column to a MySQL column
  235.  * 
  236.  * @param sourceColumn
  237.  *            the object to migrate
  238.  * @param migrationParams
  239.  *            parameters used to define the target object
  240.  * @param parent
  241.  *            parent object of the migrated object
  242.  * 
  243.  * @return returns MySQL table object
  244.  */
  245. protected com.mysql.grt.db.mysql.Column migrateColumnToMysql(
  246. com.mysql.grt.db.migration.Migration migObj, Column sourceColumn,
  247. GrtStringHashMap migrationParams, GrtObject parent) {
  249. String comments = "";
  251. // create target table
  252. com.mysql.grt.db.mysql.Column targetColumn;
  253. targetColumn = new com.mysql.grt.db.mysql.Column(parent);
  255. // log creation of target object
  256. migUtils.addMigrationLogEntry(migObj, sourceColumn, targetColumn);
  258. // do migration
  259. targetColumn.setName(migUtils.getTargetName(migrationParams,
  260. migrateIdentifier(sourceColumn.getName())));
  261. targetColumn.setOldName(sourceColumn.getName());
  262. targetColumn.setIsNullable(sourceColumn.getIsNullable());
  263. targetColumn.setPrecision(sourceColumn.getPrecision());
  264. targetColumn.setScale(sourceColumn.getScale());
  265. targetColumn.setLength(sourceColumn.getLength());
  267. if (sourceColumn.getComment() != null) {
  268. comments += " Comment: " + sourceColumn.getComment();
  269. }
  270. comments += " Hints: ";
  271. comments += " Privileges: " + sourceColumn.getPrivileges();
  272. comments += " Created: " + sourceColumn.getCreateDate() + " / "
  273. + sourceColumn.getCreateTime();
  274. comments += " Altered: " + sourceColumn.getAlterDate() + " / "
  275. + sourceColumn.getAlterTime();
  277. if (sourceColumn.getDomainName() != null)
  278. comments += " Domain (name/owner): " + sourceColumn.getDomainName()
  279. + " / " + sourceColumn.getDomainOwner();
  281. if (sourceColumn.getDefaultFunction() != null)
  282. comments += " Default function: "
  283. + sourceColumn.getDefaultFunction();
  285. targetColumn.setComment(comments);
  287. String defaultValue = sourceColumn.getDefaultValue();
  288. if (sourceColumn.getDefaultValue() != null
  289. && !sourceColumn.getDefaultValue().startsWith("DEFAULT SERIAL")) {
  290. targetColumn.setDefaultValue(defaultValue);
  291. } else {
  292. targetColumn.setDefaultValue("");
  293. }
  295. // migrate datatype
  296. SimpleDatatypeList simpleDatatypes = migObj.getTargetCatalog()
  297. .getSimpleDatatypes();
  299. String sourceDatatypeName = sourceColumn.getDatatypeName();
  301. if (!migrateColumnParamsToMySql(targetColumn, migrationParams)) {
  303. if (sourceDatatypeName.equals("SMALLINT")) {
  305. // NUMERIC
  306. // -32768 - +32767 = FIXED(5.0) + CHECK
  307. // no counterpart to MySQL signed, unsigned is done by check
  308. // constraints
  309. targetColumn.setDatatypeName("SMALLINT");
  311. } else if (sourceDatatypeName.equals("INTEGER")) {
  312. // -2147483648 and 2147483647 = FIXED(10.0) + CHECK
  313. // no counterpart to MySQL signed, unsigned is done by check
  314. // constraints
  315. targetColumn.setDatatypeName("INT");
  317. } else if (sourceDatatypeName.equals("FLOAT")) {
  318. // The data type FLOAT (p) defines a floating point number
  319. // (floating_point_literal). A column is defined that has a
  320. // floating point number with precision p (0<p<=38).
  321. // TODO: MySQL DECIMAL cannot hold all MAXDB float values
  322. targetColumn.setDatatypeName("DECIMAL");
  324. if ((migObj.getTargetCatalog().getVersion().getMajor() == 5 && migObj
  325. .getTargetCatalog().getVersion().getMinor() == 0)
  326. && (migObj.getTargetCatalog().getVersion().getRelease() >= 3 && migObj
  327. .getTargetCatalog().getVersion().getRelease() <= 5)) {
  328. // From 5.0.3 - 5.0.5 the length was 64
  329. targetColumn.setPrecision(64);
  330. } else {
  331. // Prior to 5.0.3 the length was even higher (255), so 65
  332. // should be save.
  333. targetColumn.setPrecision(65);
  334. }
  336. if (sourceColumn.getLength() <= 30) {
  337. targetColumn.setScale(sourceColumn.getLength());
  338. } else {
  339. targetColumn.setScale(30);
  340. }
  342. } else if (sourceDatatypeName.equals("FIXED")) {
  343. // The data type FIXED (p,s) defines a fixed point number
  344. // (fixed_point_literal). A column is defined that has a fixed
  345. // point
  346. // number with precision p and s number of decimal places
  347. // (0<p<=38, s<=p).
  348. // If no s is specified, it is assumed that the decimal places
  349. // are 0.
  350. // TODO: MySQL can have upmost 30 decimals, whereas MaxDB can
  351. // have 37.
  352. targetColumn.setDatatypeName("DECIMAL");
  353. if (sourceColumn.getScale() <= 30) {
  354. targetColumn.setScale(sourceColumn.getScale());
  355. } else {
  356. targetColumn.setScale(30);
  357. }
  359. } else if (sourceDatatypeName.equals("VARCHAR")) {
  361. // STRING
  363. // VARCHAR [(n)]: 0<n<=8000, VARCHAR [(n)] UNICODE: 0<n<=4000
  365. // TODO: getRelease() seems broken!
  366. boolean haveLongCharAndBinary = ((migObj.getTargetCatalog()
  367. .getVersion().getMajor() > 5)
  368. || (migObj.getTargetCatalog().getVersion().getMajor() == 5 && migObj
  369. .getTargetCatalog().getVersion().getMinor() >= 1) || (migObj
  370. .getTargetCatalog().getVersion().getMajor() == 5
  371. && migObj.getTargetCatalog().getVersion().getMinor() == 0 && migObj
  372. .getTargetCatalog().getVersion().getRelease() >= 3));
  374. if (sourceColumn.getCodeType().equals("BYTE")) {
  375. // binary data
  377. if (haveLongCharAndBinary) {
  378. // MySQL 5.0.3+, VARBINARY = VARCHAR = max length 65535
  379. targetColumn.setDatatypeName("VARBINARY");
  381. } else {
  382. // prior to 5.0.3, we have VARCHAR + binary collation
  383. // but that's not equal
  384. // to MaxDB VARCHAR BYTE, VARCHAR BYTE = binary data
  385. if (sourceColumn.getLength() < 256) {
  386. targetColumn.setDatatypeName("TINYBLOB");
  387. } else {
  388. targetColumn.setDatatypeName("BLOB");
  389. }
  390. }
  392. } else {
  393. // non-binary data - ASCII or UNICODE
  395. if (sourceColumn.getLength() < 256) {
  396. targetColumn.setDatatypeName("VARCHAR");
  397. } else {
  398. if (haveLongCharAndBinary) {
  399. targetColumn.setDatatypeName("VARCHAR");
  400. } else {
  401. targetColumn.setDatatypeName("TEXT");
  402. }
  403. }
  404. // check for UNICODE - no special handling for ASCII,
  405. // let's use the server default character set for ASCII
  406. if (sourceColumn.getCodeType().equals("UNICODE")) {
  407. targetColumn.setCharacterSetName("ucs2");
  408. }
  410. }
  412. } else if (sourceDatatypeName.equals("CHAR")) {
  413. // CHAR[ACTER] [(n)]: 0<n<=8000, CHAR[ACTER] [(n)] UNICODE:
  414. // 0<n<=4000
  416. // TODO: getRelease() seems broken!
  417. boolean haveLongCharAndBinary = ((migObj.getTargetCatalog()
  418. .getVersion().getMajor() > 5)
  419. || (migObj.getTargetCatalog().getVersion().getMajor() == 5 && migObj
  420. .getTargetCatalog().getVersion().getMinor() >= 1) || (migObj
  421. .getTargetCatalog().getVersion().getMajor() == 5
  422. && migObj.getTargetCatalog().getVersion().getMinor() == 0 && migObj
  423. .getTargetCatalog().getVersion().getRelease() >= 3));
  425. if (sourceColumn.getCodeType().equals("BYTE")) {
  426. // binary data
  428. if (haveLongCharAndBinary) {
  429. // MySQL 5.0.3+, BINARY = CHAR = max length 255
  431. if (sourceColumn.getLength() < 256) {
  432. targetColumn.setDatatypeName("BINARY");
  433. } else {
  434. targetColumn.setDatatypeName("BLOB");
  435. }
  437. } else {
  438. // prior to 5.0.3, we have CHAR + binary collation but
  439. // that's not equal
  440. // to MaxDB CHAR BYTE, CHAR BYTE = binary data
  441. if (sourceColumn.getLength() < 256) {
  442. targetColumn.setDatatypeName("TINYBLOB");
  443. } else {
  444. targetColumn.setDatatypeName("BLOB");
  445. }
  446. }
  448. } else {
  449. // non-binary data - ASCII or UNICODE
  451. if (sourceColumn.getLength() < 256) {
  452. targetColumn.setDatatypeName("CHAR");
  453. } else {
  454. targetColumn.setDatatypeName("TEXT");
  455. }
  456. // check for UNICODE - no special handling for ASCII,
  457. // let's use the server default character set for ASCII
  458. if (sourceColumn.getCodeType().equals("UNICODE")) {
  459. targetColumn.setCharacterSetName("ucs2");
  460. }
  462. }
  464. } else if (sourceDatatypeName.equals("LONG")) {
  466. // TEXT and BLOB
  468. // LONG [VARCHAR] [ASCII | BYTE]: A maximum of 2 GB of
  469. // characters can be written in a LONG column.
  470. // LONG [VARCHAR] UNICODE: A maximum of 2 GB bytes can be
  471. // written in a LONG column.
  473. if (sourceColumn.getCodeType().equals("ASCII")) {
  474. targetColumn.setDatatypeName("LONGTEXT");
  475. } else if (sourceColumn.getCodeType().equals("UNICODE")) {
  476. targetColumn.setDatatypeName("LONGTEXT");
  477. targetColumn.setCharacterSetName("ucs2");
  478. } else if (sourceColumn.getCodeType().equals("BYTE")) {
  479. targetColumn.setDatatypeName("LONGBLOB");
  480. }
  482. } else if (sourceDatatypeName.equals("DATE")) {
  484. // DATETIME
  485. // MaxDB starts from 0001-01-01, MySQL says it supports only
  486. // 1001-01-01 and up.
  487. // All values below might work, but there's no warranty
  488. targetColumn.setDatatypeName("DATE");
  490. } else if (sourceDatatypeName.equals("TIME")) {
  492. targetColumn.setDatatypeName("TIME");
  494. } else if (sourceDatatypeName.equals("TIMESTAMP")) {
  496. // Possible data loss: MaxDB supports microseconds, MySQL does
  497. // not.
  498. targetColumn.setDatatypeName("DATETIME");
  500. } else if (sourceDatatypeName.equals("BOOLEAN")) {
  502. targetColumn.setDatatypeName("TINYINT");
  504. } else {
  506. // UNKNOWN
  508. targetColumn.setDatatypeName("VARCHAR");
  509. targetColumn.setLength(255);
  511. migUtils.addMigrationLogEntry(migObj, sourceColumn,
  512. targetColumn, "The datatype "
  513. + sourceColumn.getDatatypeName()
  514. + " cannot be migrated.",
  515. MigrationUtils.logError);
  516. }
  517. }
  519. // lookup the simple datatype and set it in the column
  520. int simpleDatatypeIndex = simpleDatatypes.getIndexOfName(targetColumn
  521. .getDatatypeName());
  522. if (simpleDatatypeIndex > -1)
  523. targetColumn
  524. .setSimpleType(simpleDatatypes.get(simpleDatatypeIndex));
  525. //  
  526. // return new created, migrated object
  527. return targetColumn;
  528. }
  530. /**
  531.  * Migrates a foreign key to MySQL
  532.  * 
  533.  * @param sourceRoutine
  534.  *            the object to migrate
  535.  * @param migrationParams
  536.  *            parameters used to define the target object
  537.  * 
  538.  * @return returns MySQL table object
  539.  */
  540. protected com.mysql.grt.db.mysql.ForeignKey migrateForeignKeyToMysql(
  541. com.mysql.grt.db.migration.Migration migObj,
  542. ForeignKey sourceForeignKey, GrtStringHashMap migrationParams,
  543. GrtObject parent) {
  545. // create foreign key
  546. com.mysql.grt.db.mysql.ForeignKey targetForeignKey;
  547. targetForeignKey = new com.mysql.grt.db.mysql.ForeignKey(parent);
  549. // log creation of target object
  550. migUtils.addMigrationLogEntry(migObj, sourceForeignKey,
  551. targetForeignKey);
  553. // do migration 
  554. // NOTE: we have to add a sequence number to the FK name to ensure that it's
  555. // unique within a schema. MaxDB does not require FK constraint names to be unique,
  556. // but InnoDB does
  557. targetForeignKey.setName(migUtils.getTargetName(migrationParams,
  558. migrateIdentifier(sourceForeignKey.getName().concat(Integer.toString(fkSeqNum++)))));
  559. targetForeignKey.setOldName(sourceForeignKey.getName());
  561. String overrideRules = migrationParams.get("overrideRules");
  562. if ((overrideRules != null)
  563. && (overrideRules.compareToIgnoreCase("yes") == 0)) {
  564. targetForeignKey.setDeleteRule(migrationParams
  565. .get("defaultDeleteRule"));
  566. targetForeignKey.setUpdateRule(migrationParams
  567. .get("defaultUpdateRule"));
  568. } else {
  569. targetForeignKey.setDeleteRule(sourceForeignKey.getDeleteRule());
  570. targetForeignKey.setUpdateRule(sourceForeignKey.getUpdateRule());
  571. }
  573. targetForeignKey.setDeferability(sourceForeignKey.getDeferability());
  574. targetForeignKey
  575. .setReferedTableSchemaName(migrateIdentifier(sourceForeignKey
  576. .getReferedTableSchemaName()));
  577. targetForeignKey.setReferedTableName(migrateIdentifier(sourceForeignKey
  578. .getReferedTableName()));
  580. Table sourceTable = (Table) sourceForeignKey.getOwner();
  582. // migrate FK columns names
  583. for (int i = 0; i < sourceForeignKey.getColumns().size(); i++) {
  584. Column sourceColumnRef = (Column) sourceForeignKey.getColumns()
  585. .get(i);
  587. // get original source column
  588. Column sourceColumn = (Column) sourceTable.getColumns().get(
  589. sourceTable.getColumns().getIndexOfName(
  590. sourceColumnRef.getName()));
  592. com.mysql.grt.db.mysql.Column targetColumn = (com.mysql.grt.db.mysql.Column) (migUtils
  593. .findTargetObject(sourceColumn));
  595. targetForeignKey.getColumns().add(targetColumn);
  597. }
  599. // find target refered table
  600. Table refTable = (Table) sourceForeignKey.getReferedTable();
  601. if (refTable != null) {
  602. com.mysql.grt.db.mysql.Table targetRefTable = (com.mysql.grt.db.mysql.Table) (migUtils.findTargetObject(refTable));
  604. if (targetRefTable != null)
  605. targetForeignKey.setReferedTable(targetRefTable);
  606. }
  608. // migrate FK columns refs
  609. for (int i = 0; i < sourceForeignKey.getColumns().size(); i++) {
  610. Column sourceColumnRef = (Column) sourceForeignKey
  611. .getReferedColumns().get(i);
  613. com.mysql.grt.db.mysql.Column targetColumn = (com.mysql.grt.db.mysql.Column) (migUtils
  614. .findTargetObject(sourceColumnRef));
  616. if (targetColumn != null)
  617. targetForeignKey.getReferedColumns().add(targetColumn);
  618. }
  620. for (int i = 0; i < sourceForeignKey.getReferedColumnNames().size(); i++) {
  621. targetForeignKey.getReferedColumnNames().add(
  622. migrateIdentifier(sourceForeignKey.getReferedColumnNames()
  623. .get(i)));
  624. }
  626. if (targetForeignKey.getDeleteRule().equalsIgnoreCase("SET NULL")) {
  628. // TODO: MikeZ says it's a known limitation of the MT that the messages
  629. // do not show up on the overview of the "Manual Editing" screen
  630. migUtils.addMigrationLogEntry(migObj, sourceForeignKey, targetForeignKey, 
  631. "Currently MySQL does not support the foreign key DELETE rule SET NULL. " +
  632. "The generated SQL statement will be invalid. Please correct the SQL statement.", 
  633. MigrationUtils.logError);
  635. }
  637. // return new created, migrated object
  638. return targetForeignKey;
  639. }
  641. /**
  642.  * Migrates an MaxDB view to a MySQL view
  643.  * 
  644.  * @param sourceView
  645.  *            the object to migrate
  646.  * @param migrationParams
  647.  *            parameters used to define the target object
  648.  * 
  649.  * @return returns MySQL view object
  650.  */
  651. protected com.mysql.grt.db.mysql.View migrateViewToMysql(
  652. com.mysql.grt.db.migration.Migration migObj, View sourceView,
  653. GrtStringHashMap migrationParams, GrtObject parent) {
  655. // create target view
  656. com.mysql.grt.db.mysql.View targetView = super.migrateViewToMysql(
  657. migObj, sourceView, migrationParams, parent);
  659. // return new created, migrated object
  660. return targetView;
  661. }
  663. /**
  664.  * Migrates an MaxDB Routine to a MySQL Routine
  665.  * 
  666.  * @param sourceView
  667.  *            the object to migrate
  668.  * @param migrationParams
  669.  *            parameters used to define the target object
  670.  * 
  671.  * @return returns MySQL view object
  672.  */
  673. protected com.mysql.grt.db.mysql.Routine migrateRoutineToMysql(
  674. com.mysql.grt.db.migration.Migration migObj, Routine sourceProc,
  675. GrtStringHashMap migrationParams, GrtObject parent) {
  677. // create target Routine
  678. com.mysql.grt.db.mysql.Routine targetProc = super
  679. .migrateRoutineToMysql(migObj, sourceProc, migrationParams,
  680. parent);
  682. // return new created, migrated object
  683. return targetProc;
  684. }
  687. /**
  688.  * Migrates an MaxDB Synonym to a MySQL Synonym which will be mapped to a View in the C code
  689.  * 
  690.  * @param sourceSynonym
  691.  *            the object to migrate
  692.  * @param migrationParams
  693.  *            parameters used to define the target object
  694.  * 
  695.  * @return returns MySQL synonym object
  696.  */
  697. protected com.mysql.grt.db.mysql.Synonym migrateSynonymToMysql(
  698. com.mysql.grt.db.migration.Migration migObj, Synonym sourceSynonym,
  699. GrtStringHashMap migrationParams, GrtObject parent) {
  701. com.mysql.grt.db.mysql.Synonym targetSynonym = new com.mysql.grt.db.mysql.Synonym(parent);
  703. //  skip build-in synonyms which do not belong to the "users schema"
  704. String skipBuildin = migrationParams.get("skipBuildinSynonyms");
  706. if (skipBuildin != null && skipBuildin.equalsIgnoreCase("yes") && 
  707. (
  708. sourceSynonym.getName().equals("ACTIVECONFIGURATION") ||
  709. sourceSynonym.getName().equals("ALLOCATORSTATISTIC") ||
  710. sourceSynonym.getName().equals("ALL_CATALOG") ||
  711. sourceSynonym.getName().equals("ALL_COL_COMMENTS") ||
  712. sourceSynonym.getName().equals("ALL_COL_PRIVS") ||
  713. sourceSynonym.getName().equals("ALL_COL_PRIVS_MADE") ||
  714. sourceSynonym.getName().equals("ALL_COL_PRIVS_RECD") ||
  715. sourceSynonym.getName().equals("ALL_CONSTRAINTS") ||
  716. sourceSynonym.getName().equals("ALL_CONS_COLUMNS") ||
  717. sourceSynonym.getName().equals("ALL_DB_LINKS") ||
  718. sourceSynonym.getName().equals("ALL_DEF_AUDIT_OPTS") ||
  719. sourceSynonym.getName().equals("ALL_DEPENDENCIES") ||
  720. sourceSynonym.getName().equals("ALL_ERRORS") ||
  721. sourceSynonym.getName().equals("ALL_INDEXES") ||
  722. sourceSynonym.getName().equals("ALL_IND_COLUMNS") ||
  723. sourceSynonym.getName().equals("ALL_OBJECTS") ||
  724. sourceSynonym.getName().equals("ALL_SEQUENCES") ||
  725. sourceSynonym.getName().equals("ALL_SNAPSHOTS") ||
  726. sourceSynonym.getName().equals("ALL_SOURCE") ||
  727. sourceSynonym.getName().equals("ALL_SYNONYMS") ||
  728. sourceSynonym.getName().equals("ALL_TABLES") ||
  729. sourceSynonym.getName().equals("ALL_TAB_COLUMNS") ||
  730. sourceSynonym.getName().equals("ALL_TAB_COMMENTS") ||
  731. sourceSynonym.getName().equals("ALL_TAB_PRIVS") ||
  732. sourceSynonym.getName().equals("ALL_TAB_PRIVS_MADE") ||
  733. sourceSynonym.getName().equals("ALL_TAB_PRIVS_RECD") ||
  734. sourceSynonym.getName().equals("ALL_TRIGGERS") ||
  735. sourceSynonym.getName().equals("ALL_TRIGGER_COLS") ||
  736. sourceSynonym.getName().equals("ALL_USERS") ||
  737. sourceSynonym.getName().equals("ALL_VIEWS") ||
  738. sourceSynonym.getName().equals("AUDIT_ACTIONS") ||
  739. sourceSynonym.getName().equals("BACKUPTHREADS") ||
  740. sourceSynonym.getName().equals("CACHESTATISTICS") ||
  741. sourceSynonym.getName().equals("CAT") ||
  742. sourceSynonym.getName().equals("CATALOGCACHESTATISTICS") ||
  743. sourceSynonym.getName().equals("CLASSCONTAINERS") ||
  744. sourceSynonym.getName().equals("CLASSCONTAINER_CHAINS") ||
  745. sourceSynonym.getName().equals("CLASSCONTAINER_KEYS") ||
  746. sourceSynonym.getName().equals("CLASSCONTAINER_ROOTS") ||
  747. sourceSynonym.getName().equals("CLU") ||
  748. sourceSynonym.getName().equals("COLS") ||
  749. sourceSynonym.getName().equals("COLUMNPRIVILEGES") ||
  750. sourceSynonym.getName().equals("COLUMNS") ||
  751. sourceSynonym.getName().equals("COMMANDCACHESTATISTICS") ||
  752. sourceSynonym.getName().equals("COMMANDSTATISTICS") ||
  753. sourceSynonym.getName().equals("CONFIGURATION") ||
  754. sourceSynonym.getName().equals("CONNECTEDUSERS") ||
  755. sourceSynonym.getName().equals("CONNECTPARAMETERS") ||
  756. sourceSynonym.getName().equals("CONSISTENTVIEWS") ||
  757. sourceSynonym.getName().equals("CONSTRAINTS") ||
  758. sourceSynonym.getName().equals("DATACACHE") ||
  759. sourceSynonym.getName().equals("DATASTATISTICS") ||
  760. sourceSynonym.getName().equals("DATASTATISTICSRESET") ||
  761. sourceSynonym.getName().equals("DATAVOLUMES") ||
  762. sourceSynonym.getName().equals("DBA_2PC_NEIGHBORS") ||
  763. sourceSynonym.getName().equals("DBA_2PC_PENDING") ||
  764. sourceSynonym.getName().equals("DBA_AUDIT_EXISTS") ||
  765. sourceSynonym.getName().equals("DBA_AUDIT_OBJECT") ||
  766. sourceSynonym.getName().equals("DBA_AUDIT_SESSION") ||
  767. sourceSynonym.getName().equals("DBA_AUDIT_STATEMENT") ||
  768. sourceSynonym.getName().equals("DBA_AUDIT_TRAIL") ||
  769. sourceSynonym.getName().equals("DBA_BLOCKERS") ||
  770. sourceSynonym.getName().equals("DBA_CATALOG") ||
  771. sourceSynonym.getName().equals("DBA_CLUSTERS") ||
  772. sourceSynonym.getName().equals("DBA_CLU_COLUMNS") ||
  773. sourceSynonym.getName().equals("DBA_COL_COMMENTS") ||
  774. sourceSynonym.getName().equals("DBA_COL_PRIVS") ||
  775. sourceSynonym.getName().equals("DBA_CONSTRAINTS") ||
  776. sourceSynonym.getName().equals("DBA_CONS_COLUMNS") ||
  777. sourceSynonym.getName().equals("DBA_DATA_FILES") ||
  778. sourceSynonym.getName().equals("DBA_DB_LINKS") ||
  779. sourceSynonym.getName().equals("DBA_DDL_LOCKS") ||
  780. sourceSynonym.getName().equals("DBA_DEPENDENCIES") ||
  781. sourceSynonym.getName().equals("DBA_DML_LOCKS") ||
  782. sourceSynonym.getName().equals("DBA_ERRORS") ||
  783. sourceSynonym.getName().equals("DBA_EXP_FILES") ||
  784. sourceSynonym.getName().equals("DBA_EXP_OBJECTS") ||
  785. sourceSynonym.getName().equals("DBA_EXP_VERSION") ||
  786. sourceSynonym.getName().equals("DBA_EXTENTS") ||
  787. sourceSynonym.getName().equals("DBA_FREE_SPACE") ||
  788. sourceSynonym.getName().equals("DBA_INDEXES") ||
  789. sourceSynonym.getName().equals("DBA_IND_COLUMNS") ||
  790. sourceSynonym.getName().equals("DBA_LOCKS") ||
  791. sourceSynonym.getName().equals("DBA_OBJECTS") ||
  792. sourceSynonym.getName().equals("DBA_OBJECT_SIZE") ||
  793. sourceSynonym.getName().equals("DBA_OBJ_AUDIT_OPTS") ||
  794. sourceSynonym.getName().equals("DBA_PRIV_AUDIT_OPTS") ||
  795. sourceSynonym.getName().equals("DBA_PROFILES") ||
  796. sourceSynonym.getName().equals("DBA_ROLES") ||
  797. sourceSynonym.getName().equals("DBA_ROLE_PRIVS") ||
  798. sourceSynonym.getName().equals("DBA_ROLLBACK_SEGS") ||
  799. sourceSynonym.getName().equals("DBA_SEGMENTS") ||
  800. sourceSynonym.getName().equals("DBA_SEQUENCES") ||
  801. sourceSynonym.getName().equals("DBA_SNAPSHOTS") ||
  802. sourceSynonym.getName().equals("DBA_SNAPSHOT_LOGS") ||
  803. sourceSynonym.getName().equals("DBA_SOURCE") ||
  804. sourceSynonym.getName().equals("DBA_STMT_AUDIT_OPTS") ||
  805. sourceSynonym.getName().equals("DBA_SYNONYMS") ||
  806. sourceSynonym.getName().equals("DBA_SYS_PRIVS") ||
  807. sourceSynonym.getName().equals("DBA_TABLES") ||
  808. sourceSynonym.getName().equals("DBA_TABLESPACES") ||
  809. sourceSynonym.getName().equals("DBA_TAB_COLUMNS") ||
  810. sourceSynonym.getName().equals("DBA_TAB_COMMENTS") ||
  811. sourceSynonym.getName().equals("DBA_TAB_PRIVS") ||
  812. sourceSynonym.getName().equals("DBA_TRIGGERS") ||
  813. sourceSynonym.getName().equals("DBA_TRIGGER_COLS") ||
  814. sourceSynonym.getName().equals("DBA_TS_QUOTAS") ||
  815. sourceSynonym.getName().equals("DBA_USERS") ||
  816. sourceSynonym.getName().equals("DBA_VIEWS") ||
  817. sourceSynonym.getName().equals("DBA_WAITERS") ||
  818. sourceSynonym.getName().equals("DBPARAMETERS") ||
  819. sourceSynonym.getName().equals("DBPROCEDURES") ||
  820. sourceSynonym.getName().equals("DBPROCPARAMINFO") ||
  821. sourceSynonym.getName().equals("DBPROCPARAMS") ||
  822. sourceSynonym.getName().equals("DBTIMES") ||
  823. sourceSynonym.getName().equals("DB_STATE") ||
  824. sourceSynonym.getName().equals("DICT") ||
  825. sourceSynonym.getName().equals("DICTIONARY") ||
  826. sourceSynonym.getName().equals("DICT_COLUMNS") ||
  827. sourceSynonym.getName().equals("DOMAINCONSTRAINTS") ||
  828. sourceSynonym.getName().equals("DOMAINS") ||
  829. sourceSynonym.getName().equals("DUAL") ||
  830. sourceSynonym.getName().equals("ESTIMATED_PAGES") ||
  831. sourceSynonym.getName().equals("EXCEPTIONS") ||
  832. sourceSynonym.getName().equals("FILEDIRECTORIES") ||
  833. sourceSynonym.getName().equals("FILES") ||
  834. sourceSynonym.getName().equals("FOREIGNKEYCOLUMNS") ||
  835. sourceSynonym.getName().equals("FOREIGNKEYS") ||
  836. sourceSynonym.getName().equals("FUNCTIONS") ||
  837. sourceSynonym.getName().equals("GARBAGECOLLECTOR_STATISTICS") ||
  838. sourceSynonym.getName().equals("GLOBAL_NAME") ||
  839. sourceSynonym.getName().equals("HISTORYINFO") ||
  840. sourceSynonym.getName().equals("HOTSTANDBYCOMPONENT") ||
  841. sourceSynonym.getName().equals("HOTSTANDBYGROUP") ||
  842. sourceSynonym.getName().equals("IND") ||
  843. sourceSynonym.getName().equals("INDEXCOLUMNS") ||
  844. sourceSynonym.getName().equals("INDEXES") ||
  845. sourceSynonym.getName().equals("INDEXPAGES") ||
  846. sourceSynonym.getName().equals("INDEXSTATISTICS") ||
  847. sourceSynonym.getName().equals("INSTANCE") ||
  848. sourceSynonym.getName().equals("INTERNAL_STATE") ||
  849. sourceSynonym.getName().equals("IOBUFFERCACHES") ||
  850. sourceSynonym.getName().equals("INDEXES") ||
  851. sourceSynonym.getName().equals("INDEXPAGES") ||
  852. sourceSynonym.getName().equals("INDEXSTATISTICS") ||
  853. sourceSynonym.getName().equals("INSTANCE") ||
  854. sourceSynonym.getName().equals("INTERNAL_STATE") ||
  855. sourceSynonym.getName().equals("IOBUFFERCACHES") ||
  856. sourceSynonym.getName().equals("IOTHREADSTATISTICS") ||
  857. sourceSynonym.getName().equals("IOTHREADSTATISTICSRESET") ||
  858. sourceSynonym.getName().equals("LOCKLISTSTATISTICS") ||
  859. sourceSynonym.getName().equals("LOCKS") ||
  860. sourceSynonym.getName().equals("LOCKSTATISTICS") ||
  861. sourceSynonym.getName().equals("LOCK_HOLDER") ||
  862. sourceSynonym.getName().equals("LOCK_REQUESTOR") ||
  863. sourceSynonym.getName().equals("LOCK_WAITS") ||
  864. sourceSynonym.getName().equals("LOGINFORMATION") ||
  865. sourceSynonym.getName().equals("LOGQUEUESTATISTICS") ||
  866. sourceSynonym.getName().equals("LOGSTATISTICS") ||
  867. sourceSynonym.getName().equals("LOGSTATISTICSRESET") ||
  868. sourceSynonym.getName().equals("LOGVOLUMES") ||
  869. sourceSynonym.getName().equals("MACHINECONFIGURATION") ||
  870. sourceSynonym.getName().equals("MACHINEUTILIZATION") ||
  871. sourceSynonym.getName().equals("MAPCHARSETS") ||
  872. sourceSynonym.getName().equals("MEMORYALLOCATORSTATISTICS") ||
  873. sourceSynonym.getName().equals("MEMORYHOLDERS") ||
  874. sourceSynonym.getName().equals("MEMORY_HOLDERS") ||
  875. sourceSynonym.getName().equals("MONITOR") ||
  876. sourceSynonym.getName().equals("MONITOR_CACHES") ||
  877. sourceSynonym.getName().equals("MONITOR_LOAD") ||
  878. sourceSynonym.getName().equals("MONITOR_LOCK") ||
  879. sourceSynonym.getName().equals("MONITOR_LOG") ||
  880. sourceSynonym.getName().equals("MONITOR_LONG") ||
  881. sourceSynonym.getName().equals("MONITOR_OMS") ||
  882. sourceSynonym.getName().equals("MONITOR_PAGES") ||
  883. sourceSynonym.getName().equals("MONITOR_ROW") ||
  884. sourceSynonym.getName().equals("MONITOR_TRANS") ||
  885. sourceSynonym.getName().equals("OBJ") ||
  886. sourceSynonym.getName().equals("OBJECTLOCKS") ||
  887. sourceSynonym.getName().equals("OMSDIAGNOSE") ||
  888. sourceSynonym.getName().equals("OMSLOCKS") ||
  889. sourceSynonym.getName().equals("OMS_HEAP_STATISTICS") ||
  890. sourceSynonym.getName().equals("OMS_LOCKOBJ_INFO") ||
  891. sourceSynonym.getName().equals("OMS_MEMORY_USAGE") ||
  892. sourceSynonym.getName().equals("OMS_VERSIONS") ||
  893. sourceSynonym.getName().equals("OPTIMIZERINFORMATION") ||
  894. sourceSynonym.getName().equals("OPTIMIZERSTATISTICS") ||
  895. sourceSynonym.getName().equals("PACKAGES") ||
  896. sourceSynonym.getName().equals("PAGES") ||
  897. sourceSynonym.getName().equals("PARAMETERS") ||
  898. sourceSynonym.getName().equals("PARSINFOS") ||
  899. sourceSynonym.getName().equals("PUBLIC_DEPENDENCY") ||
  900. sourceSynonym.getName().equals("READERWRITERLOCKINFORMATION") ||
  901. sourceSynonym.getName().equals("READERWRITERLOCKSTATISTICS") ||
  902. sourceSynonym.getName().equals("READERWRITERLOCKSTATISTICSRESET") ||
  903. sourceSynonym.getName().equals("READERWRITERLOCKWAITINGTASKS") ||
  904. sourceSynonym.getName().equals("RESOURCE_COST") ||
  905. sourceSynonym.getName().equals("RESTARTINFORMATION") ||
  906. sourceSynonym.getName().equals("ROLEPRIVILEGES") ||
  907. sourceSynonym.getName().equals("ROLES") ||
  908. sourceSynonym.getName().equals("ROLE_ROLE_PRIVS") ||
  909. sourceSynonym.getName().equals("ROLE_SYS_PRIVS") ||
  910. sourceSynonym.getName().equals("ROLE_TAB_PRIVS") ||
  911. sourceSynonym.getName().equals("ROOTS") ||
  912. sourceSynonym.getName().equals("RUNNING_COMMANDS") ||
  913. sourceSynonym.getName().equals("RUNNING_PARSEIDS") ||
  914. sourceSynonym.getName().equals("SCHEMAPRIVILEGES") ||
  915. sourceSynonym.getName().equals("SCHEMAS") ||
  916. sourceSynonym.getName().equals("SEQ") ||
  917. sourceSynonym.getName().equals("SEQUENCES") ||
  918. sourceSynonym.getName().equals("SERVERDBS") ||
  919. sourceSynonym.getName().equals("SERVERDBSTATISTICS") ||
  920. sourceSynonym.getName().equals("SERVERTASKS") ||
  921. sourceSynonym.getName().equals("SESSIONS") ||
  922. sourceSynonym.getName().equals("SESSION_PRIVS") ||
  923. sourceSynonym.getName().equals("SESSION_ROLES") ||
  924. sourceSynonym.getName().equals("SNAPSHOTS") ||
  925. sourceSynonym.getName().equals("SPINLOCKPOOLSTATISTICS") ||
  926. sourceSynonym.getName().equals("SPINLOCKS") ||
  927. sourceSynonym.getName().equals("SPINLOCKSTATISTICS") ||
  928. sourceSynonym.getName().equals("STMT_AUDIT_OPTION_MAP") ||
  929. sourceSynonym.getName().equals("SYN") ||
  930. sourceSynonym.getName().equals("SYNONYMS") ||
  931. sourceSynonym.getName().equals("SYSCHECKTABLELOG") ||
  932. sourceSynonym.getName().equals("SYSCMD_ANALYZE") ||
  933. sourceSynonym.getName().equals("SYSDATA_ANALYZE") ||
  934. sourceSynonym.getName().equals("SYSMONDATA") ||
  935. sourceSynonym.getName().equals("SYSMONITOR") ||
  936. sourceSynonym.getName().equals("SYSMON_ACTIVE_TASK") ||
  937. sourceSynonym.getName().equals("SYSMON_BACKUPIOACCESS") ||
  938. sourceSynonym.getName().equals("SYSMON_CONNECTION") ||
  939. sourceSynonym.getName().equals("SYSMON_DW") ||
  940. sourceSynonym.getName().equals("SYSMON_DW_ACTIVE") ||
  941. sourceSynonym.getName().equals("SYSMON_DW_RUNNABLE") ||
  942. sourceSynonym.getName().equals("SYSMON_IOACCESS") ||
  943. sourceSynonym.getName().equals("SYSMON_IOTHREAD") ||
  944. sourceSynonym.getName().equals("SYSMON_REGION") ||
  945. sourceSynonym.getName().equals("SYSMON_RUNNABLE") ||
  946. sourceSynonym.getName().equals("SYSMON_SPECIAL_THREAD") ||
  947. sourceSynonym.getName().equals("SYSMON_STORAGE") ||
  948. sourceSynonym.getName().equals("SYSMON_SV") ||
  949. sourceSynonym.getName().equals("SYSMON_SV_ACTIVE") ||
  950. sourceSynonym.getName().equals("SYSMON_SV_RUNNABLE") ||
  951. sourceSynonym.getName().equals("SYSMON_TASK") ||
  952. sourceSynonym.getName().equals("SYSMON_TASK_DETAIL") ||
  953. sourceSynonym.getName().equals("SYSMON_TOTALCOUNT") ||
  954. sourceSynonym.getName().equals("SYSMON_UKTHREAD") ||
  955. sourceSynonym.getName().equals("SYSMON_US") ||
  956. sourceSynonym.getName().equals("SYSMON_US_ACTIVE") ||
  957. sourceSynonym.getName().equals("SYSMON_US_RUNNABLE") ||
  958. sourceSynonym.getName().equals("SYSPARSEID") ||
  959. sourceSynonym.getName().equals("SYSSTATISTICS") ||
  960. sourceSynonym.getName().equals("SYSTEMTRIGGERS") ||
  961. sourceSynonym.getName().equals("SYSUPDSTATLOG") ||
  962. sourceSynonym.getName().equals("SYSUPDSTATWANTED") ||
  963. sourceSynonym.getName().equals("TABLEPRIVILEGES") ||
  964. sourceSynonym.getName().equals("TABLES") ||
  965. sourceSynonym.getName().equals("TABLESTATISTICS") ||
  966. sourceSynonym.getName().equals("TABLE_PRIVILEGE_MAP") ||
  967. sourceSynonym.getName().equals("TABS") ||
  968. sourceSynonym.getName().equals("TASKLOADBALANCINGINFORMATION") ||
  969. sourceSynonym.getName().equals("TASKLOADBALANCINGTASKGROUPSTATES") ||
  970. sourceSynonym.getName().equals("TASKLOADBALANCINGTASKGROUPSTATES") ||
  971. sourceSynonym.getName().equals("TASKLOADBALANCINGTASKMOVES") ||
  972. sourceSynonym.getName().equals("TRANSACTIONHISTORY") ||
  973. sourceSynonym.getName().equals("TRANSACTIONS") ||
  974. sourceSynonym.getName().equals("TRIGGERS") ||
  975. sourceSynonym.getName().equals("UNLOADEDSTATEMENTS") ||
  976. sourceSynonym.getName().equals("USERS") ||
  977. sourceSynonym.getName().equals("USERSTATISTICS") ||
  978. sourceSynonym.getName().equals("USER_AUDIT_OBJECT") ||
  979. sourceSynonym.getName().equals("USER_AUDIT_SESSION") ||
  980. sourceSynonym.getName().equals("USER_AUDIT_STATEMENT") ||
  981. sourceSynonym.getName().equals("USER_AUDIT_TRAIL") ||
  982. sourceSynonym.getName().equals("USER_CATALOG") ||
  983. sourceSynonym.getName().equals("USER_CLUSTERS") ||
  984. sourceSynonym.getName().equals("USER_CLU_COLUMNS") ||
  985. sourceSynonym.getName().equals("USER_COL_COMMENTS") ||
  986. sourceSynonym.getName().equals("USER_COL_PRIVS") ||
  987. sourceSynonym.getName().equals("USER_COL_PRIVS_MADE") ||
  988. sourceSynonym.getName().equals("USER_COL_PRIVS_RECD") ||
  989. sourceSynonym.getName().equals("USER_CONSTRAINTS") ||
  990. sourceSynonym.getName().equals("USER_CONS_COLUMNS") ||
  991. sourceSynonym.getName().equals("USER_DB_LINKS") ||
  992. sourceSynonym.getName().equals("USER_DEPENDENCIES") ||
  993. sourceSynonym.getName().equals("USER_ERRORS") ||
  994. sourceSynonym.getName().equals("USER_EXTENTS") ||
  995. sourceSynonym.getName().equals("USER_FREE_SPACE") ||
  996. sourceSynonym.getName().equals("USER_INDEXES") ||
  997. sourceSynonym.getName().equals("USER_IND_COLUMNS") ||
  998. sourceSynonym.getName().equals("USER_OBJECTS") ||
  999. sourceSynonym.getName().equals("USER_OBJECT_SIZE") ||
  1000. sourceSynonym.getName().equals("USER_OBJ_AUDIT_OPTS") ||
  1001. sourceSynonym.getName().equals("USER_RESOURCE_LIMITS") ||
  1002. sourceSynonym.getName().equals("USER_ROLE_PRIVS") ||
  1003. sourceSynonym.getName().equals("USER_SEGMENTS") ||
  1004. sourceSynonym.getName().equals("USER_SEQUENCES") ||
  1005. sourceSynonym.getName().equals("USER_SNAPSHOTS") ||
  1006. sourceSynonym.getName().equals("USER_SNAPSHOT_LOGS") ||
  1007. sourceSynonym.getName().equals("USER_SOURCE") ||
  1008. sourceSynonym.getName().equals("USER_SYNONYMS") ||
  1009. sourceSynonym.getName().equals("USER_SYS_PRIVS") ||
  1010. sourceSynonym.getName().equals("USER_TABLES") ||
  1011. sourceSynonym.getName().equals("USER_TABLESPACES") ||
  1012. sourceSynonym.getName().equals("USER_TAB_COLUMNS") ||
  1013. sourceSynonym.getName().equals("USER_TAB_COMMENTS") ||
  1014. sourceSynonym.getName().equals("USER_TAB_PRIVS") ||
  1015. sourceSynonym.getName().equals("USER_TAB_PRIVS_MADE") ||
  1016. sourceSynonym.getName().equals("USER_TAB_PRIVS_RECD") ||
  1017. sourceSynonym.getName().equals("USER_TRIGGERS") ||
  1018. sourceSynonym.getName().equals("USER_TRIGGER_COLS") ||
  1019. sourceSynonym.getName().equals("USER_TS_QUOTAS") ||
  1020. sourceSynonym.getName().equals("USER_USERS") ||
  1021. sourceSynonym.getName().equals("USER_VIEWS") ||
  1022. sourceSynonym.getName().equals("V$NLS_PARAMETERS") ||
  1023. sourceSynonym.getName().equals("VERSION") ||
  1024. sourceSynonym.getName().equals("VERSIONS") ||
  1025. sourceSynonym.getName().equals("VIEWCOLUMNS") ||
  1026. sourceSynonym.getName().equals("VIEWDEFS") ||
  1027. sourceSynonym.getName().equals("VIEWS")
  1028. )
  1029. ) {
  1030. targetSynonym = null;
  1032. } else {
  1034. // Synonym name = View name
  1035. targetSynonym.setName(sourceSynonym.getName());
  1037. // Table that is refered by the Synonym
  1038. Table refTable = (Table) sourceSynonym.getReferedObject();
  1039. if (refTable != null) {
  1040. com.mysql.grt.db.mysql.Table targetRefTable = (com.mysql.grt.db.mysql.Table) (migUtils.findTargetObject(refTable));
  1042. if (targetRefTable != null)
  1043. targetSynonym.setReferedObject(targetRefTable);
  1044. }
  1045. }
  1047. return targetSynonym;
  1048. }
  1051. /**
  1052.  * Migrates a column to a MySQL column
  1053.  * 
  1054.  * @param sourceTrigger
  1055.  *            the object to migrate
  1056.  * @param migrationParams
  1057.  *            parameters used to define the target object
  1058.  * @param parent
  1059.  *            parent object of the migrated object
  1060.  * 
  1061.  * @return returns MySQL trigger object
  1062.  */
  1063. protected com.mysql.grt.db.mysql.Trigger migrateTriggerToMysql(
  1064. com.mysql.grt.db.migration.Migration migObj, Trigger sourceTrigger,
  1065. GrtStringHashMap migrationParams, GrtObject parent) {
  1067. com.mysql.grt.db.mysql.Trigger targetTrigger = new com.mysql.grt.db.mysql.Trigger(parent);
  1069. targetTrigger.setName(sourceTrigger.getName());
  1070. targetTrigger.setOldName(sourceTrigger.getName());
  1071. targetTrigger.setComment(sourceTrigger.getComment());
  1072. targetTrigger.setTiming(sourceTrigger.getTiming());
  1073. targetTrigger.setEvent(sourceTrigger.getEvent());
  1074. targetTrigger.setStatement(sourceTrigger.getStatement());
  1076. /*
  1077.  
  1078.  
  1080. //  Table that is refered by the Synonym
  1081. Table refTable = (Table) sourceSynonym.getReferedObject();
  1082. if (refTable != null) {
  1083. com.mysql.grt.db.mysql.Table targetRefTable = (com.mysql.grt.db.mysql.Table) (migUtils.findTargetObject(refTable));
  1085. if (targetRefTable != null)
  1086. targetSynonym.setReferedObject(targetRefTable);
  1087. }
  1088. */
  1090. return targetTrigger;
  1091. }
  1092. /**
  1093.  * Generates information about the schema to MySQL migration method
  1094.  * 
  1095.  * @return returns a Method with predefined migration parameters
  1096.  */
  1097. private Method getMigrateSchemaToMysqlInfo() {
  1099. // create method description
  1100. Method method = new Method(null);
  1101. method.setName("migrateSchemaToMysql");
  1102. method.setModuleName("MigrationMaxdb");
  1103. method.setCaption("MaxDB Default");
  1104. method.setDesc("Default method to migrate an MaxDB schema to MySQL.");
  1105. method.setSourceStructName("db.maxdb.Schema");
  1106. method.setTargetPackageName("db.mysql");
  1107. method.setRating(1);
  1109. addMigrateSchemaToMysqlInfoParameters(method);
  1111. return method;
  1112. }
  1114. /**
  1115.  * Generates information about the MaxDB Table to MySQL migration method
  1116.  * 
  1117.  * @return returns a Method with predefined migration parameters
  1118.  */
  1119. private Method getMigrateTableToMysqlInfo() {
  1121. // create migrateMaxdbTable method
  1122. Method method = new Method(null);
  1123. method.setName("migrateTableToMysql");
  1124. method.setModuleName("MigrationMaxdb");
  1125. method.setCaption("MaxDB Default");
  1126. method.setDesc("Default method to migrate an MaxDB table to MySQL.");
  1127. method.setSourceStructName("db.maxdb.Table");
  1128. method.setTargetPackageName("db.mysql");
  1129. method.setRating(1);
  1131. addMigrateTableToMysqlInfoParameters(method);
  1133. return method;
  1134. }
  1136. protected void addMigrateTableToMysqlInfoParameters(Method method) {
  1138. // specify the parameters the method understands
  1139. GrtStringHashMap paramNames = new GrtStringHashMap();
  1140. method.setParams(paramNames);
  1141. paramNames.add("engine", "INNODB");
  1142. paramNames.add("charset", "");
  1143. paramNames.add("collation", "");
  1144. paramNames.add("addAutoincrement", "yes");
  1146. // create a list of parameter groups the user can choose from
  1147. ParameterGroupList paramGroupList = new ParameterGroupList();
  1148. method.setParamGroups(paramGroupList);
  1150. // add parameter group
  1151. ParameterGroup paramGroup = new ParameterGroup(method);
  1152. paramGroupList.add(paramGroup);
  1153. paramGroup.setName("Data consistency");
  1154. paramGroup
  1155. .setDesc("Standard parameter group. "
  1156. + "The migrated tables will use the "
  1157. + "InnoDB storage "
  1158. + "engine to offer transactional and "
  1159. + "foreign key support.");
  1160. GrtStringHashMap params = new GrtStringHashMap();
  1161. paramGroup.setParams(params);
  1162. params.add("engine", "INNODB");
  1163. params.add("addAutoincrement", "no");
  1165. // add parameter group
  1166. paramGroup = new ParameterGroup(method);
  1167. paramGroupList.add(paramGroup);
  1168. paramGroup.setName("Statistical data");
  1169. paramGroup.setDesc("Choose this parameter group for tables that "
  1170. + "contain lots of data which does not need "
  1171. + "transaction safety. This method is ideal "
  1172. + "for logging information or statistical data.");
  1173. params = new GrtStringHashMap();
  1174. paramGroup.setParams(params);
  1175. params.add("engine", "MyISAM");
  1176. params.add("addAutoincrement", "no");
  1178. // add parameter group
  1179. paramGroup = new ParameterGroup(method);
  1180. paramGroupList.add(paramGroup);
  1181. paramGroup.setName("Data consistency / multilanguage");
  1182. paramGroup.setDesc("The migrated tables will use the "
  1183. + "InnoDB storage " + "engine to offer transactional and "
  1184. + "foreign key support and use " + "UTF8 as default charset.");
  1185. params = new GrtStringHashMap();
  1186. paramGroup.setParams(params);
  1187. params.add("engine", "INNODB");
  1188. params.add("charset", "utf8");
  1189. params.add("collation", "utf8_general_ci");
  1190. params.add("addAutoincrement", "no");
  1192. // add parameter group
  1193. paramGroup = new ParameterGroup(method);
  1194. paramGroupList.add(paramGroup);
  1195. paramGroup.setName("Data consistency / UNICODE");
  1196. paramGroup.setDesc("The migrated tables will use the "
  1197. + "InnoDB storage " + "engine to offer transactional and "
  1198. + "foreign key support and use "
  1199. + "UNICODE as default charset.");
  1200. params = new GrtStringHashMap();
  1201. paramGroup.setParams(params);
  1202. params.add("engine", "INNODB");
  1203. params.add("charset", "ucs2");
  1204. params.add("collation", "ucs2_general_ci");
  1205. params.add("addAutoincrement", "no");
  1207. }
  1209. /**
  1210.  * Generates information about the Column to MySQL migration method
  1211.  * 
  1212.  * @return returns a Method with predefined migration parameters
  1213.  */
  1214. private Method getMigrateColumnToMysqlInfo() {
  1216. // create method description
  1217. Method method = new Method(null);
  1218. method.setName("migrateColumnToMysql");
  1219. method.setModuleName("MigrationMaxdb");
  1220. method.setCaption("MaxDB Default");
  1221. method.setDesc("Default method to migrate a MaxDB column to MySQL.");
  1222. method.setSourceStructName("db.maxdb.Column");
  1223. method.setTargetPackageName("db.mysql");
  1224. method.setRating(1);
  1226. addMigrateColumnToMysqlInfoParameters(method);
  1228. return method;
  1229. }
  1231. /**
  1232.  * Generates information about the ForeignKey to MySQL migration method
  1233.  * 
  1234.  * @return returns a Method with predefined migration parameters
  1235.  */
  1236. private Method getMigrateForeignKeyToMysqlInfo() {
  1238. // create method description
  1239. Method method = new Method(null);
  1240. method.setName("migrateForeignKeyToMysql");
  1241. method.setModuleName("MigrationMaxdb");
  1242. method.setCaption("MaxDB");
  1243. method.setDesc("MaxDB method to migrate a foreign key to MySQL.");
  1244. method.setSourceStructName("db.maxdb.ForeignKey");
  1245. method.setTargetPackageName("db.mysql");
  1246. method.setRating(1);
  1248. addMigrateForeignKeyToMysqlInfoParameters(method);
  1250. return method;
  1251. }
  1253. /**
  1254.  * Generates information about the View to MySQL migration method
  1255.  * 
  1256.  * @return returns a Method with predefined migration parameters
  1257.  */
  1258. private Method getMigrateViewToMysqlInfo() {
  1260. // create migrateMaxdbTable method
  1261. Method method = new Method(null);
  1262. method.setName("migrateViewToMysql");
  1263. method.setModuleName("MigrationMaxdb");
  1264. method.setCaption("MaxDB Default");
  1265. method.setDesc("Default method to migrate an MaxDB view to MySQL.");
  1266. method.setSourceStructName("db.maxdb.View");
  1267. method.setTargetPackageName("db.mysql");
  1268. method.setRating(1);
  1270. addMigrateViewToMysqlInfoParameters(method);
  1272. return method;
  1273. }
  1275. /**
  1276.  * Generates information about the View to MySQL migration method
  1277.  * 
  1278.  * @return returns a Method with predefined migration parameters
  1279.  */
  1280. private Method getMigrateRoutineToMysqlInfo() {
  1282. // create migrateMaxdbTable method
  1283. Method method = new Method(null);
  1284. method.setName("migrateRoutineToMysql");
  1285. method.setModuleName("MigrationMaxdb");
  1286. method.setCaption("MaxDB Default");
  1287. method.setDesc("Default method to migrate an MaxDB routine to MySQL.");
  1288. method.setSourceStructName("db.maxdb.Routine");
  1289. method.setTargetPackageName("db.mysql");
  1290. method.setRating(1);
  1292. addMigrateRoutineToMysqlInfoParameters(method);
  1294. return method;
  1295. }
  1297. /**
  1298.  * Generates information about the Synonym to MySQL migration method
  1299.  * 
  1300.  * @return returns a Method with predefined migration parameters
  1301.  */
  1302. private Method getMigrateSynonymToMysql() {
  1304. // create migrateMaxdbTable method
  1305. Method method = new Method(null);
  1306. method.setName("migrateSynonymToMysql");
  1307. method.setModuleName("MigrationMaxdb");
  1308. method.setCaption("MaxDB Default");
  1309. method.setDesc("Default method to migrate a MaxDB synonym to MySQL.");
  1310. method.setSourceStructName("db.maxdb.Synonym");
  1311. method.setTargetPackageName("db.mysql");
  1312. method.setRating(1);
  1314. addMigrateSynonymToMysqlInfoParameters(method);
  1316. return method;
  1318. }
  1320. protected void addMigrateSynonymToMysqlInfoParameters(Method method) {
  1322. // specify the parameters the method understands
  1323. GrtStringHashMap paramNames = new GrtStringHashMap();
  1324. method.setParams(paramNames);
  1325. paramNames.add("skipBuildinSynonyms", "yes");
  1327. // create a list of parameter groups the user can choose from
  1328. ParameterGroupList paramGroupList = new ParameterGroupList();
  1329. method.setParamGroups(paramGroupList);
  1331. // add parameter group
  1332. ParameterGroup paramGroup = new ParameterGroup(method);
  1333. paramGroupList.add(paramGroup);
  1334. paramGroup.setName("Skip build-in synonyms");
  1335. paramGroup
  1336. .setDesc("Standard parameter group. " +
  1337. "Build-in synonyms will be skipped."
  1338. );
  1339. GrtStringHashMap params = new GrtStringHashMap();
  1340. paramGroup.setParams(params);
  1341. params.add("skipBuildinSynonyms", "yes");
  1343. }
  1345. /**
  1346.  * Generates information about the Triger to MySQL migration method
  1347.  * 
  1348.  * @return returns a Method with predefined migration parameters
  1349.  */
  1350. private Method getMigrateTriggerToMysql() {
  1352. // create migrateMaxdbTable method
  1353. Method method = new Method(null);
  1354. method.setName("migrateTriggerToMysql");
  1355. method.setModuleName("MigrationMaxdb");
  1356. method.setCaption("MaxDB Default");
  1357. method.setDesc("Default method to migrate a MaxDB trigger to MySQL.");
  1358. method.setSourceStructName("db.maxdb.Trigger");
  1359. method.setTargetPackageName("db.mysql");
  1360. method.setRating(1);
  1362. return method;
  1363. }
  1365. }