AMBARI-19168 Supports udf migration for hive and pig migration and multi-user select for all migrations. (Ishan Bhatt via gauravn7)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/672fdf06 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/672fdf06 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/672fdf06 Branch: refs/heads/trunk Commit: 672fdf06b5c9f2b18bfca95c86b25251bd1ac98d Parents: 49a6929 Author: Gaurav Nagar <[email protected]> Authored: Tue Jan 3 14:04:22 2017 +0530 Committer: Gaurav Nagar <[email protected]> Committed: Tue Jan 3 14:08:03 2017 +0530 ---------------------------------------------------------------------- .../savedqueryset/MysqlQuerySetAmbariDB.java | 30 +- .../savedqueryset/OracleQuerySetAmbariDB.java | 29 +- .../hive/savedqueryset/QuerySetAmbariDB.java | 76 +++- .../pig/udfqueryset/MysqlQuerySetAmbariDB.java | 48 +++ .../pig/udfqueryset/OracleQuerySetAmbariDB.java | 46 +++ .../udfqueryset/PostgressQuerySetAmbariDB.java | 22 ++ .../pig/udfqueryset/QuerySetAmbariDB.java | 82 ++++ .../hive/historyqueryset/MysqlQuerySet.java | 23 -- .../historyqueryset/MysqlQuerySetHueDB.java | 23 ++ .../hive/historyqueryset/OracleQuerySet.java | 61 --- .../historyqueryset/OracleQuerySetHueDB.java | 66 ++++ .../hive/historyqueryset/PostgressQuerySet.java | 22 -- .../historyqueryset/PostgressQuerySetHueDB.java | 22 ++ .../hive/historyqueryset/QuerySet.java | 130 ------- .../hive/historyqueryset/QuerySetHueDB.java | 139 +++++++ .../hive/historyqueryset/SqliteQuerySet.java | 22 -- .../historyqueryset/SqliteQuerySetHueDB.java | 22 ++ .../hive/savedqueryset/MysqlQuerySet.java | 23 -- .../hive/savedqueryset/MysqlQuerySetHueDb.java | 23 ++ .../hive/savedqueryset/OracleQuerySet.java | 65 ---- .../hive/savedqueryset/OracleQuerySetHueDb.java | 71 ++++ .../hive/savedqueryset/PostgressQuerySet.java | 22 -- .../savedqueryset/PostgressQuerySetHueDb.java | 22 ++ .../hive/savedqueryset/QuerySet.java | 134 ------- .../hive/savedqueryset/QuerySetHueDb.java | 144 +++++++ .../hive/savedqueryset/SqliteQuerySet.java | 22 -- .../hive/savedqueryset/SqliteQuerySetHueDb.java | 22 ++ .../pig/jobqueryset/MysqlQuerySet.java | 22 -- .../pig/jobqueryset/MysqlQuerySetHueDb.java | 22 ++ .../pig/jobqueryset/OracleQuerySet.java | 65 ---- .../pig/jobqueryset/OracleQuerySetHueDb.java | 69 ++++ .../pig/jobqueryset/PostgressQuerySet.java | 22 -- .../pig/jobqueryset/PostgressQuerySetHueDb.java | 22 ++ .../huequeryset/pig/jobqueryset/QuerySet.java | 132 ------- .../pig/jobqueryset/QuerySetHueDb.java | 141 +++++++ .../pig/jobqueryset/SqliteQuerySet.java | 22 -- .../pig/jobqueryset/SqliteQuerySetHueDb.java | 22 ++ .../pig/savedscriptqueryset/MysqlQuerySet.java | 22 -- .../savedscriptqueryset/MysqlQuerySetHueDb.java | 22 ++ .../pig/savedscriptqueryset/OracleQuerySet.java | 60 --- .../OracleQuerySetHueDb.java | 64 +++ .../savedscriptqueryset/PostgressQuerySet.java | 67 ---- .../PostgressQuerySetHueDb.java | 67 ++++ .../pig/savedscriptqueryset/QuerySet.java | 135 ------- .../pig/savedscriptqueryset/QuerySetHueDb.java | 142 +++++++ .../pig/savedscriptqueryset/SqliteQuerySet.java | 24 -- .../SqliteQuerySetHueDb.java | 24 ++ .../pig/udfqueryset/MysqlQuerySet.java | 22 ++ .../pig/udfqueryset/OracleQuerySet.java | 41 ++ .../pig/udfqueryset/PostgressQuerySet.java | 23 ++ .../huequeryset/pig/udfqueryset/QuerySet.java | 75 ++++ .../pig/udfqueryset/SqliteQuerySet.java | 24 ++ .../migration/InitiateJobMigration.java | 5 + .../HiveHistoryMigrationUtility.java | 154 ++++---- ...HiveHistoryQueryMigrationImplementation.java | 34 +- .../hive/historyquery/HiveHistoryStartJob.java | 1 + .../HiveSavedQueryMigrationImplementation.java | 117 ++++-- .../HiveSavedQueryMigrationUtility.java | 191 +++++---- .../hive/savedquery/HiveSavedQueryStartJob.java | 1 + .../pigjob/PigJobMigrationImplementation.java | 42 +- .../pig/pigjob/PigJobMigrationUtility.java | 358 ++++++++--------- .../migration/pig/pigjob/PigJobStartJob.java | 1 + .../pig/pigscript/PigSavedScriptStartJob.java | 1 + .../PigScriptMigrationImplementation.java | 36 +- .../pigscript/PigScriptMigrationUtility.java | 136 ++++--- .../pigudf/PigUdfMigrationImplementation.java | 387 +++++++++++++++++++ .../pig/pigudf/PigUdfMigrationUtility.java | 235 +++++++++++ .../migration/pig/pigudf/PigUdfStartJob.java | 69 ++++ .../resources/scripts/models/HiveModel.java | 48 ++- .../scripts/models/MigrationResponse.java | 6 +- .../resources/scripts/models/PigModel.java | 20 + .../app/models/checkprogress.js | 3 +- .../ui/hueambarimigration-view/app/router.js | 2 +- .../app/routes/home-page/hive-history.js | 45 ++- .../app/routes/home-page/hive-saved-query.js | 44 ++- .../app/routes/home-page/pig-job.js | 45 ++- .../app/routes/home-page/pig-script.js | 45 ++- .../app/routes/home-page/pig-udf.js | 121 ++++++ .../app/templates/home-page.hbs | 5 +- .../app/templates/home-page/hive-history.hbs | 4 +- .../templates/home-page/hive-saved-query.hbs | 4 +- .../app/templates/home-page/pig-job.hbs | 4 +- .../app/templates/home-page/pig-script.hbs | 4 +- .../app/templates/home-page/pig-udf.hbs | 109 ++++++ 84 files changed, 3407 insertions(+), 1632 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/MysqlQuerySetAmbariDB.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/MysqlQuerySetAmbariDB.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/MysqlQuerySetAmbariDB.java index 204ace9..691df89 100644 --- a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/MysqlQuerySetAmbariDB.java +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/MysqlQuerySetAmbariDB.java @@ -29,10 +29,11 @@ public class MysqlQuerySetAmbariDB extends QuerySetAmbariDB { } @Override - protected String getTableIdSqlFromInstanceNameSavedQuery() { - return "select id from viewentity where class_name LIKE 'org.apache.ambari.view.%hive%.resources.savedQueries.SavedQuery' and view_instance_name=?;"; + protected String getTableIdSqlFromInstanceName(String sequence) { + return "select id from viewentity where class_name LIKE '" + sequence + "' and view_instance_name=?;"; } + @Override protected String getSqlMaxDSidFromTableIdHistoryQuery(int id) { return "select MAX(cast(ds_id as integer)) as max from DS_JOBIMPL_" + id + ";"; @@ -54,6 +55,16 @@ public class MysqlQuerySetAmbariDB extends QuerySetAmbariDB { } @Override + protected String getSqlInsertFileResources(int id) { + return "INSERT INTO DS_FILERESOURCEITEM_" + id + " values (?,?,?,?);"; + } + + @Override + protected String getSqlInsertHiveUdf(int id) { + return "INSERT INTO DS_UDF_" + id + " values (?,?,?,?,?);"; + } + + @Override protected String getRevSqlSavedQuery(int id, String maxcount) { return "delete from DS_SAVEDQUERY_" + id + " where ds_id='" + maxcount + "';"; } @@ -62,12 +73,19 @@ public class MysqlQuerySetAmbariDB extends QuerySetAmbariDB { protected String getRevSqlHistoryQuery(int id, String maxcount) { return "delete from DS_JOBIMPL_" + id + " where ds_id='" + maxcount + "';"; } + + @Override + protected String getSqlSequenceNoFromAmbariSequence() { + return "select sequence_value from ambari_sequences where sequence_name=?;"; + } + @Override - protected String getSqlSequenceNoFromAmbariSequence(int id) { - return "select sequence_value from ambari_sequences where sequence_name ='ds_savedquery_"+id+"_id_seq';"; + protected String getSqlUpdateSequenceNo() { + return "update ambari_sequences set sequence_value=? where sequence_name=?;"; } + @Override - protected String getSqlUpdateSequenceNo(int id) { - return "update ambari_sequences set sequence_value=? where sequence_name='ds_savedquery_"+id+"_id_seq';"; + protected String getSqlUdfFileNameAndOwners(int id) { + return "select ds_name, ds_owner from ds_fileresourceitem_" + id + ";"; } } http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/OracleQuerySetAmbariDB.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/OracleQuerySetAmbariDB.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/OracleQuerySetAmbariDB.java index 5efcc1c..522deec 100644 --- a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/OracleQuerySetAmbariDB.java +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/OracleQuerySetAmbariDB.java @@ -25,8 +25,8 @@ public class OracleQuerySetAmbariDB extends QuerySetAmbariDB { } @Override - protected String getTableIdSqlFromInstanceNameSavedQuery() { - return "select id from viewentity where class_name LIKE 'org.apache.ambari.view.hive.resources.savedQueries.SavedQuery' and view_instance_name=?"; + protected String getTableIdSqlFromInstanceName(String sequence) { + return "select id from viewentity where class_name LIKE '" + sequence + "' and view_instance_name=?"; } @Override @@ -48,6 +48,16 @@ public class OracleQuerySetAmbariDB extends QuerySetAmbariDB { } @Override + protected String getSqlInsertFileResources(int id) { + return "INSERT INTO ds_fileresourceitem_" + id + " values (?,?,?,?)"; + } + + @Override + protected String getSqlInsertHiveUdf(int id) { + return "INSERT INTO ds_udf_" + id + " values (?,?,?,?,?)"; + } + + @Override protected String getRevSqlSavedQuery(int id, String maxcount) { return "delete from ds_savedquery_" + id + " where ds_id='" + maxcount + "'"; } @@ -55,12 +65,19 @@ public class OracleQuerySetAmbariDB extends QuerySetAmbariDB { protected String getRevSqlHistoryQuery(int id, String maxcount) { return "delete from ds_jobimpl_" + id + " where ds_id='" + maxcount + "'"; } + @Override - protected String getSqlSequenceNoFromAmbariSequence(int id) { - return "select sequence_value from ambari_sequences where sequence_name ='ds_savedquery_"+id+"_id_seq'"; + protected String getSqlSequenceNoFromAmbariSequence() { + return "select sequence_value from ambari_sequences where sequence_name=?;"; } + + @Override + protected String getSqlUpdateSequenceNo() { + return "update ambari_sequences set sequence_value=? where sequence_name=?;"; + } + @Override - protected String getSqlUpdateSequenceNo(int id) { - return "update ambari_sequences set sequence_value=? where sequence_name='ds_savedquery_"+id+"_id_seq'"; + protected String getSqlUdfFileNameAndOwners(int id) { + return "select ds_name, ds_owner from ds_fileresourceitem_" + id + ";"; } } http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/QuerySetAmbariDB.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/QuerySetAmbariDB.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/QuerySetAmbariDB.java index 3bfe73d..5d928b6 100644 --- a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/QuerySetAmbariDB.java +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/hive/savedqueryset/QuerySetAmbariDB.java @@ -27,24 +27,30 @@ import java.sql.SQLException; public abstract class QuerySetAmbariDB { - public PreparedStatement getTableIdFromInstanceNameSavedquery(Connection connection, String instance) throws SQLException { + public PreparedStatement getTableIdFromInstanceName(Connection connection, String instance, String tableSequence) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(getTableIdSqlFromInstanceNameSavedQuery()); + PreparedStatement prSt = connection.prepareStatement(getTableIdSqlFromInstanceName(tableSequence)); prSt.setString(1, instance); return prSt; } - public PreparedStatement updateSequenceNoInAmbariSequence(Connection connection, int seqNo, int id) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(getSqlUpdateSequenceNo(id)); + public PreparedStatement updateSequenceNoInAmbariSequence(Connection connection, int seqNo, String sequenceName) throws SQLException { + + PreparedStatement prSt = connection.prepareStatement(getSqlUpdateSequenceNo()); prSt.setInt(1, seqNo); + prSt.setString(2, sequenceName); return prSt; } - public PreparedStatement getSequenceNoFromAmbariSequence(Connection connection,int id) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(getSqlSequenceNoFromAmbariSequence(id)); + public PreparedStatement getSequenceNoFromAmbariSequence(Connection connection,String sequenceName) throws SQLException { + + PreparedStatement prSt = connection.prepareStatement(getSqlSequenceNoFromAmbariSequence()); + + prSt.setString(1, sequenceName); + return prSt; } @@ -101,6 +107,39 @@ public abstract class QuerySetAmbariDB { return prSt; } + + public PreparedStatement insertToFileResources(Connection connection, int id, String maxcount, String fileName, String udfOwner, String udfPath) throws SQLException { + + PreparedStatement prSt = connection.prepareStatement(getSqlInsertFileResources(id)); + + prSt.setString(1, maxcount); + prSt.setString(2, fileName); + prSt.setString(3, udfOwner); + prSt.setString(4, udfPath); + + return prSt; + + } + + public PreparedStatement insertToHiveUdf(Connection connection, int id, String maxcount1, String maxcount2, String className, String name, String owner) throws SQLException { + + PreparedStatement prSt = connection.prepareStatement(getSqlInsertHiveUdf(id)); + + prSt.setString(1, maxcount1); + prSt.setString(2, className); + prSt.setString(3, maxcount2); + prSt.setString(4, name); + prSt.setString(5, owner); + + return prSt; + } + + public PreparedStatement getUdfFileNamesAndOwners(Connection connection, int id) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(getSqlUdfFileNameAndOwners(id)); + return prSt; + + } + public String revertSqlHistoryQuery(int id, String maxcount) throws SQLException { return getRevSqlHistoryQuery(id, maxcount); @@ -115,10 +154,11 @@ public abstract class QuerySetAmbariDB { return "select MAX(cast(ds_id as integer)) as max from ds_savedquery_" + id + ";"; } - protected String getTableIdSqlFromInstanceNameSavedQuery() { - return "select id from viewentity where class_name LIKE 'org.apache.ambari.view.%hive%.resources.savedQueries.SavedQuery' and view_instance_name=?;"; + protected String getTableIdSqlFromInstanceName(String sequence) { + return "select id from viewentity where class_name LIKE '" + sequence + "' and view_instance_name=?;"; } + protected String getSqlMaxDSidFromTableIdHistoryQuery(int id) { return "select MAX(cast(ds_id as integer)) as max from ds_jobimpl_" + id + ";"; } @@ -135,6 +175,14 @@ public abstract class QuerySetAmbariDB { return "INSERT INTO ds_savedquery_" + id + " values (?,?,?,?,?,?);"; } + protected String getSqlInsertFileResources(int id) { + return "INSERT INTO ds_fileresourceitem_" + id + " values (?,?,?,?);"; + } + + protected String getSqlInsertHiveUdf(int id) { + return "INSERT INTO ds_udf_" + id + " values (?,?,?,?,?);"; + } + protected String getRevSqlSavedQuery(int id, String maxcount) { return "delete from ds_savedquery_" + id + " where ds_id='" + maxcount + "';"; } @@ -143,12 +191,16 @@ public abstract class QuerySetAmbariDB { return "delete from ds_jobimpl_" + id + " where ds_id='" + maxcount + "';"; } - protected String getSqlSequenceNoFromAmbariSequence(int id) { - return "select sequence_value from ambari_sequences where sequence_name ='ds_savedquery_"+id+"_id_seq';"; + protected String getSqlSequenceNoFromAmbariSequence() { + return "select sequence_value from ambari_sequences where sequence_name=?;"; + } + + protected String getSqlUpdateSequenceNo() { + return "update ambari_sequences set sequence_value=? where sequence_name=?;"; } - protected String getSqlUpdateSequenceNo(int id) { - return "update ambari_sequences set sequence_value=? where sequence_name='ds_savedquery_"+id+"_id_seq';"; + protected String getSqlUdfFileNameAndOwners(int id) { + return "select ds_name, ds_owner from ds_fileresourceitem_" + id + ";"; } } http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/MysqlQuerySetAmbariDB.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/MysqlQuerySetAmbariDB.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/MysqlQuerySetAmbariDB.java new file mode 100644 index 0000000..47203c9 --- /dev/null +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/MysqlQuerySetAmbariDB.java @@ -0,0 +1,48 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * <p/> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p/> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.ambari.view.huetoambarimigration.datasource.queryset.ambariqueryset.pig.udfqueryset; + +/** + * over rides method for Mysql specific queries + */ + +public class MysqlQuerySetAmbariDB extends org.apache.ambari.view.huetoambarimigration.datasource.queryset.ambariqueryset.pig.udfqueryset.QuerySetAmbariDB { + + @Override + protected String getSqlMaxDSidFromTableId(int id) { + return "select max( cast(ds_id as unsigned) ) as max from DS_UDF_" + id + ";"; + } + @Override + protected String getTableIdSqlFromInstanceName() { + return "select id from viewentity where class_name LIKE 'org.apache.ambari.view.pig.resources.udf.models.UDF' and view_instance_name=?;"; + } + @Override + protected String getSqlinsertToPigUdf(int id) { + return "INSERT INTO DS_UDF_" + id + " values (?,?,?,?);"; + } + + @Override + protected String getSqlSequenceNoFromAmbariSequence(int id) { + return "select sequence_value from ambari_sequences where sequence_name ='ds_udf_"+id+"_id_seq';"; + } + @Override + protected String getSqlUpdateSequenceNo(int id) { + return "update ambari_sequences set sequence_value=? where sequence_name='ds_udf"+id+"_id_seq';"; + } + +} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/OracleQuerySetAmbariDB.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/OracleQuerySetAmbariDB.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/OracleQuerySetAmbariDB.java new file mode 100644 index 0000000..9ac4540 --- /dev/null +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/OracleQuerySetAmbariDB.java @@ -0,0 +1,46 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * <p/> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p/> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.ambari.view.huetoambarimigration.datasource.queryset.ambariqueryset.pig.udfqueryset; + +public class OracleQuerySetAmbariDB extends QuerySetAmbariDB { + /* + * Overriding methods for Oracle specific queries + * */ + @Override + protected String getSqlMaxDSidFromTableId(int id) { + return "select MAX(cast(ds_id as integer)) as max from ds_udf_" + id + ""; + } + @Override + protected String getTableIdSqlFromInstanceName() { + return "select id from viewentity where class_name LIKE 'org.apache.ambari.view.pig.resources.udf.models.UDF' and view_instance_name=?"; + } + @Override + protected String getSqlinsertToPigUdf(int id) { + return "INSERT INTO ds_udf_" + id + " values (?,?,?,?)"; + } + + @Override + protected String getSqlSequenceNoFromAmbariSequence(int id) { + return "select sequence_value from ambari_sequences where sequence_name ='ds_udf_"+id+"_id_seq'"; + } + @Override + protected String getSqlUpdateSequenceNo(int id) { + return "update ambari_sequences set sequence_value=? where sequence_name='ds_udf_"+id+"_id_seq'"; + } + +} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/PostgressQuerySetAmbariDB.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/PostgressQuerySetAmbariDB.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/PostgressQuerySetAmbariDB.java new file mode 100644 index 0000000..47d98fd --- /dev/null +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/PostgressQuerySetAmbariDB.java @@ -0,0 +1,22 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * <p/> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p/> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.ambari.view.huetoambarimigration.datasource.queryset.ambariqueryset.pig.udfqueryset; + + +public class PostgressQuerySetAmbariDB extends QuerySetAmbariDB { +} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/QuerySetAmbariDB.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/QuerySetAmbariDB.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/QuerySetAmbariDB.java new file mode 100644 index 0000000..85dac1c --- /dev/null +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/ambariqueryset/pig/udfqueryset/QuerySetAmbariDB.java @@ -0,0 +1,82 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * <p/> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p/> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.ambari.view.huetoambarimigration.datasource.queryset.ambariqueryset.pig.udfqueryset; + +import java.sql.Connection; +import java.sql.PreparedStatement; +import java.sql.SQLException; + +/** + * Pig Script prepared statement + */ +public abstract class QuerySetAmbariDB { + + public PreparedStatement getTableIdFromInstanceName(Connection connection, String instance) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(getTableIdSqlFromInstanceName()); + prSt.setString(1, instance); + return prSt; + } + + public PreparedStatement getSequenceNoFromAmbariSequence(Connection connection,int id) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(getSqlSequenceNoFromAmbariSequence(id)); + return prSt; + } + + + public PreparedStatement insertToPigUdf(Connection connection, int id, String maxcount1, String udfName, String owner,String path) throws SQLException { + + PreparedStatement prSt = connection.prepareStatement(getSqlinsertToPigUdf(id)); + prSt.setString(1, maxcount1); + prSt.setString(2, udfName); + prSt.setString(3, owner); + prSt.setString(4, path); + + return prSt; + } + + + public PreparedStatement updateSequenceNoInAmbariSequence(Connection connection, int seqNo, int id) throws SQLException { + + PreparedStatement prSt = connection.prepareStatement(getSqlUpdateSequenceNo(id)); + + prSt.setInt(1, seqNo); + + return prSt; + } + + protected String getSqlMaxDSidFromTableId(int id) { + return "select MAX(cast(ds_id as integer)) as max from ds_udf_" + id + ";"; + } + + protected String getTableIdSqlFromInstanceName() { + return "select id from viewentity where class_name LIKE 'org.apache.ambari.view.pig.resources.udf.models.UDF' and view_instance_name=?;"; + } + + protected String getSqlinsertToPigUdf(int id) { + return "INSERT INTO ds_udf_" + id + " values (?,?,?,?);"; + } + + + protected String getSqlSequenceNoFromAmbariSequence(int id) { + return "select sequence_value from ambari_sequences where sequence_name ='ds_udf_"+id+"_id_seq';"; + } + + protected String getSqlUpdateSequenceNo(int id) { + return "update ambari_sequences set sequence_value=? where sequence_name='ds_udf_"+id+"_id_seq';"; + } +} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/MysqlQuerySet.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/MysqlQuerySet.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/MysqlQuerySet.java deleted file mode 100644 index d379f88..0000000 --- a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/MysqlQuerySet.java +++ /dev/null @@ -1,23 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * <p/> - * http://www.apache.org/licenses/LICENSE-2.0 - * <p/> - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.historyqueryset; - - -public class MysqlQuerySet extends QuerySet { - -} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/MysqlQuerySetHueDB.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/MysqlQuerySetHueDB.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/MysqlQuerySetHueDB.java new file mode 100644 index 0000000..4a81579 --- /dev/null +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/MysqlQuerySetHueDB.java @@ -0,0 +1,23 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * <p/> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p/> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.historyqueryset; + + +public class MysqlQuerySetHueDB extends QuerySetHueDB { + +} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/OracleQuerySet.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/OracleQuerySet.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/OracleQuerySet.java deleted file mode 100644 index 4afb222..0000000 --- a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/OracleQuerySet.java +++ /dev/null @@ -1,61 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * <p/> - * http://www.apache.org/licenses/LICENSE-2.0 - * <p/> - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.historyqueryset; - - -public class OracleQuerySet extends QuerySet { - - @Override - protected String fetchuserIdfromUsernameSql() { - return "select id from auth_user where username=?"; - } - @Override - protected String fetchHueQueriesNoStartdateNoEnddateSql() { - return "select query from beeswax_queryhistory where owner_id =?"; - } - @Override - protected String fetchHueQueriesNoStartdateYesEnddateSql() { - return "select query from beeswax_queryhistory where owner_id =? AND submission_date <= date(?)"; - } - @Override - protected String fetchHueQueriesYesStartdateNoEnddateSql() { - return "select query from beeswax_queryhistory where owner_id =? AND submission_date >= date(?)"; - } - @Override - protected String fetchHueQueriesYesStartdateYesEnddateSql() { - return "select query from beeswax_queryhistory where owner_id =? AND submission_date >= date(?) AND submission_date <= date(?)"; - } - @Override - protected String fetchHueQueriesNoStartdateNoEnddateYesallUserSql() { - return "select query from beeswax_queryhistory"; - } - @Override - protected String fetchHueQueriesNoStartdateYesEnddateYesallUserSql() { - return "select query from beeswax_queryhistory where submission_date <= date(?)"; - } - @Override - protected String fetchHueQueriesYesStartdateNoEnddateYesallUserSql() { - return "select query from beeswax_queryhistory where submission_date >= date(?)"; - - } - @Override - protected String fetchHueQueriesYesStartdateYesEnddateYesallUserSql() { - return "select query from beeswax_queryhistory where submission_date >= date(?) AND submission_date <= date(?)"; - - } -} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/OracleQuerySetHueDB.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/OracleQuerySetHueDB.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/OracleQuerySetHueDB.java new file mode 100644 index 0000000..32edde4 --- /dev/null +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/OracleQuerySetHueDB.java @@ -0,0 +1,66 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * <p/> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p/> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.historyqueryset; + + +public class OracleQuerySetHueDB extends QuerySetHueDB { + + @Override + protected String fetchuserIdfromUsernameSql() { + return "select id from auth_user where username=?"; + } + @Override + protected String fetchHueQueriesNoStartdateNoEnddateSql() { + return "select query from beeswax_queryhistory where owner_id =?"; + } + @Override + protected String fetchHueQueriesNoStartdateYesEnddateSql() { + return "select query from beeswax_queryhistory where owner_id =? AND submission_date <= date(?)"; + } + @Override + protected String fetchHueQueriesYesStartdateNoEnddateSql() { + return "select query from beeswax_queryhistory where owner_id =? AND submission_date >= date(?)"; + } + @Override + protected String fetchHueQueriesYesStartdateYesEnddateSql() { + return "select query from beeswax_queryhistory where owner_id =? AND submission_date >= date(?) AND submission_date <= date(?)"; + } + @Override + protected String fetchHueQueriesNoStartdateNoEnddateYesallUserSql() { + return "select query from beeswax_queryhistory"; + } + @Override + protected String fetchHueQueriesNoStartdateYesEnddateYesallUserSql() { + return "select query from beeswax_queryhistory where submission_date <= date(?)"; + } + @Override + protected String fetchHueQueriesYesStartdateNoEnddateYesallUserSql() { + return "select query from beeswax_queryhistory where submission_date >= date(?)"; + + } + @Override + protected String fetchHueQueriesYesStartdateYesEnddateYesallUserSql() { + return "select query from beeswax_queryhistory where submission_date >= date(?) AND submission_date <= date(?)"; + + } + @Override + protected String fetchUserNamSql() { + return "select username from auth_user where id = ?"; + } + +} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/PostgressQuerySet.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/PostgressQuerySet.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/PostgressQuerySet.java deleted file mode 100644 index 829582a..0000000 --- a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/PostgressQuerySet.java +++ /dev/null @@ -1,22 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * <p/> - * http://www.apache.org/licenses/LICENSE-2.0 - * <p/> - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.historyqueryset; - - -public class PostgressQuerySet extends QuerySet { -} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/PostgressQuerySetHueDB.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/PostgressQuerySetHueDB.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/PostgressQuerySetHueDB.java new file mode 100644 index 0000000..f303aa7 --- /dev/null +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/PostgressQuerySetHueDB.java @@ -0,0 +1,22 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * <p/> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p/> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.historyqueryset; + + +public class PostgressQuerySetHueDB extends QuerySetHueDB { +} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/QuerySet.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/QuerySet.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/QuerySet.java deleted file mode 100644 index 8d2aad4..0000000 --- a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/QuerySet.java +++ /dev/null @@ -1,130 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * <p/> - * http://www.apache.org/licenses/LICENSE-2.0 - * <p/> - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.historyqueryset; - -import java.sql.Connection; -import java.sql.PreparedStatement; -import java.sql.SQLException; - - -public abstract class QuerySet { - - - public PreparedStatement getUseridfromUserName(Connection connection, String username) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchuserIdfromUsernameSql()); - prSt.setString(1, username); - return prSt; - } - - public PreparedStatement getQueriesNoStartDateNoEndDate(Connection connection, int id) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateNoEnddateSql()); - prSt.setInt(1, id); - return prSt; - } - - public PreparedStatement getQueriesNoStartDateYesEndDate(Connection connection, int id, String enddate) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateYesEnddateSql()); - prSt.setInt(1, id); - prSt.setString(2, enddate); - return prSt; - } - - public PreparedStatement getQueriesYesStartDateNoEndDate(Connection connection, int id, String startdate) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateNoEnddateSql()); - prSt.setInt(1, id); - prSt.setString(2, startdate); - return prSt; - } - - public PreparedStatement getQueriesYesStartDateYesEndDate(Connection connection, int id, String startdate, String endate) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateYesEnddateSql()); - prSt.setInt(1, id); - prSt.setString(2, startdate); - prSt.setString(3, endate); - return prSt; - } - - /** - * for all user - */ - public PreparedStatement getQueriesNoStartDateNoEndDateAllUser(Connection connection) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateNoEnddateYesallUserSql()); - return prSt; - } - - public PreparedStatement getQueriesNoStartDateYesEndDateAllUser(Connection connection, String enddate) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateYesEnddateYesallUserSql()); - prSt.setString(1, enddate); - return prSt; - } - - public PreparedStatement getQueriesYesStartDateNoEndDateAllUser(Connection connection, String startdate) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateNoEnddateYesallUserSql()); - prSt.setString(1, startdate); - return prSt; - } - - public PreparedStatement getQueriesYesStartDateYesEndDateAllUser(Connection connection, String startdate, String endate) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateYesEnddateYesallUserSql()); - prSt.setString(1, startdate); - prSt.setString(2, endate); - return prSt; - } - - - protected String fetchuserIdfromUsernameSql() { - return "select id from auth_user where username=?;"; - - } - - protected String fetchHueQueriesNoStartdateNoEnddateSql() { - return "select query from beeswax_queryhistory where owner_id =?;"; - } - - protected String fetchHueQueriesNoStartdateYesEnddateSql() { - return "select query from beeswax_queryhistory where owner_id =? AND submission_date <= date(?);"; - } - - protected String fetchHueQueriesYesStartdateNoEnddateSql() { - return "select query from beeswax_queryhistory where owner_id =? AND submission_date >= date(?);"; - } - - protected String fetchHueQueriesYesStartdateYesEnddateSql() { - return "select query from beeswax_queryhistory where owner_id =? AND submission_date >= date(?) AND submission_date <= date(?);"; - } - - protected String fetchHueQueriesNoStartdateNoEnddateYesallUserSql() { - return "select query from beeswax_queryhistory;"; - } - - protected String fetchHueQueriesNoStartdateYesEnddateYesallUserSql() { - return "select query from beeswax_queryhistory where submission_date <= date(?);"; - } - - protected String fetchHueQueriesYesStartdateNoEnddateYesallUserSql() { - return "select query from beeswax_queryhistory where submission_date >= date(?);"; - - } - - protected String fetchHueQueriesYesStartdateYesEnddateYesallUserSql() { - return "select query from beeswax_queryhistory where submission_date >= date(?) AND submission_date <= date(?);"; - - } - - -} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/QuerySetHueDB.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/QuerySetHueDB.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/QuerySetHueDB.java new file mode 100644 index 0000000..a9e9695 --- /dev/null +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/QuerySetHueDB.java @@ -0,0 +1,139 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * <p/> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p/> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.historyqueryset; + +import java.sql.Connection; +import java.sql.PreparedStatement; +import java.sql.SQLException; + + +public abstract class QuerySetHueDB { + + + public PreparedStatement getUseridfromUserName(Connection connection, String username) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchuserIdfromUsernameSql()); + prSt.setString(1, username); + return prSt; + } + + public PreparedStatement getQueriesNoStartDateNoEndDate(Connection connection, int id) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateNoEnddateSql()); + prSt.setInt(1, id); + return prSt; + } + + public PreparedStatement getQueriesNoStartDateYesEndDate(Connection connection, int id, String enddate) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateYesEnddateSql()); + prSt.setInt(1, id); + prSt.setString(2, enddate); + return prSt; + } + + public PreparedStatement getQueriesYesStartDateNoEndDate(Connection connection, int id, String startdate) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateNoEnddateSql()); + prSt.setInt(1, id); + prSt.setString(2, startdate); + return prSt; + } + + public PreparedStatement getQueriesYesStartDateYesEndDate(Connection connection, int id, String startdate, String endate) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateYesEnddateSql()); + prSt.setInt(1, id); + prSt.setString(2, startdate); + prSt.setString(3, endate); + return prSt; + } + + /** + * for all user + */ + public PreparedStatement getQueriesNoStartDateNoEndDateAllUser(Connection connection) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateNoEnddateYesallUserSql()); + return prSt; + } + + public PreparedStatement getQueriesNoStartDateYesEndDateAllUser(Connection connection, String enddate) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateYesEnddateYesallUserSql()); + prSt.setString(1, enddate); + return prSt; + } + + public PreparedStatement getQueriesYesStartDateNoEndDateAllUser(Connection connection, String startdate) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateNoEnddateYesallUserSql()); + prSt.setString(1, startdate); + return prSt; + } + + public PreparedStatement getQueriesYesStartDateYesEndDateAllUser(Connection connection, String startdate, String endate) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateYesEnddateYesallUserSql()); + prSt.setString(1, startdate); + prSt.setString(2, endate); + return prSt; + } + + public PreparedStatement getUserName(Connection connection, int id) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchUserNamSql()); + prSt.setInt(1, id); + return prSt; + } + + protected String fetchuserIdfromUsernameSql() { + return "select id from auth_user where username=?;"; + + } + + protected String fetchHueQueriesNoStartdateNoEnddateSql() { + return "select owner_id, query from beeswax_queryhistory where owner_id =?;"; + } + + protected String fetchHueQueriesNoStartdateYesEnddateSql() { + return "select owner_id, query from beeswax_queryhistory where owner_id =? AND submission_date <= date(?);"; + } + + protected String fetchHueQueriesYesStartdateNoEnddateSql() { + return "select owner_id, query from beeswax_queryhistory where owner_id =? AND submission_date >= date(?);"; + } + + protected String fetchHueQueriesYesStartdateYesEnddateSql() { + return "select owner_id, query from beeswax_queryhistory where owner_id =? AND submission_date >= date(?) AND submission_date <= date(?);"; + } + + protected String fetchHueQueriesNoStartdateNoEnddateYesallUserSql() { + return "select owner_id, query from beeswax_queryhistory;"; + } + + protected String fetchHueQueriesNoStartdateYesEnddateYesallUserSql() { + return "select owner_id, query from beeswax_queryhistory where submission_date <= date(?);"; + } + + protected String fetchHueQueriesYesStartdateNoEnddateYesallUserSql() { + return "select owner_id, query from beeswax_queryhistory where submission_date >= date(?);"; + + } + + protected String fetchHueQueriesYesStartdateYesEnddateYesallUserSql() { + return "select owner_id, query from beeswax_queryhistory where submission_date >= date(?) AND submission_date <= date(?);"; + + } + + protected String fetchUserNamSql() { + return "select username from auth_user where id = ?;"; + } + + +} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/SqliteQuerySet.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/SqliteQuerySet.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/SqliteQuerySet.java deleted file mode 100644 index 417df3a..0000000 --- a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/SqliteQuerySet.java +++ /dev/null @@ -1,22 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * <p/> - * http://www.apache.org/licenses/LICENSE-2.0 - * <p/> - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.historyqueryset; - - -public class SqliteQuerySet extends QuerySet { -} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/SqliteQuerySetHueDB.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/SqliteQuerySetHueDB.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/SqliteQuerySetHueDB.java new file mode 100644 index 0000000..febdb95 --- /dev/null +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/historyqueryset/SqliteQuerySetHueDB.java @@ -0,0 +1,22 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * <p/> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p/> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.historyqueryset; + + +public class SqliteQuerySetHueDB extends QuerySetHueDB { +} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/MysqlQuerySet.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/MysqlQuerySet.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/MysqlQuerySet.java deleted file mode 100644 index d91633d..0000000 --- a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/MysqlQuerySet.java +++ /dev/null @@ -1,23 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * <p/> - * http://www.apache.org/licenses/LICENSE-2.0 - * <p/> - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.savedqueryset; - - -public class MysqlQuerySet extends QuerySet { -} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/MysqlQuerySetHueDb.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/MysqlQuerySetHueDb.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/MysqlQuerySetHueDb.java new file mode 100644 index 0000000..fad3c50 --- /dev/null +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/MysqlQuerySetHueDb.java @@ -0,0 +1,23 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * <p/> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p/> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.savedqueryset; + + +public class MysqlQuerySetHueDb extends QuerySetHueDb { +} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/OracleQuerySet.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/OracleQuerySet.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/OracleQuerySet.java deleted file mode 100644 index 3190885..0000000 --- a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/OracleQuerySet.java +++ /dev/null @@ -1,65 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * <p/> - * http://www.apache.org/licenses/LICENSE-2.0 - * <p/> - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.savedqueryset; - - -public class OracleQuerySet extends QuerySet { - - @Override - protected String fetchuserIdfromUsernameSql() { - return "select id from auth_user where username=?"; - - } - @Override - protected String fetchHueQueriesNoStartdateNoEnddateSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =?"; - } - @Override - protected String fetchHueQueriesNoStartdateYesEnddateSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =? AND mtime <= date(?)"; - } - @Override - protected String fetchHueQueriesYesStartdateNoEnddateSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =? AND mtime >= date(?)"; - - } - @Override - protected String fetchHueQueriesYesStartdateYesEnddateSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =? AND mtime >= date(?) AND mtime <= date(?)"; - - } - @Override - protected String fetchHueQueriesNoStartdateNoEnddateYesallUserSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'"; - } - @Override - protected String fetchHueQueriesNoStartdateYesEnddateYesallUserSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query' AND mtime <= date(?)"; - - } - @Override - protected String fetchHueQueriesYesStartdateNoEnddateYesallUserSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query' AND mtime >= date(?)"; - - } - @Override - protected String fetchHueQueriesYesStartdateYesEnddateYesallUserSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query' AND mtime >= date(?) AND mtime <= date(?)"; - - } -} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/OracleQuerySetHueDb.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/OracleQuerySetHueDb.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/OracleQuerySetHueDb.java new file mode 100644 index 0000000..f1e1ede --- /dev/null +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/OracleQuerySetHueDb.java @@ -0,0 +1,71 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * <p/> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p/> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.savedqueryset; + + +public class OracleQuerySetHueDb extends QuerySetHueDb { + + @Override + protected String fetchuserIdfromUsernameSql() { + return "select id from auth_user where username=?"; + + } + @Override + protected String fetchHueQueriesNoStartdateNoEnddateSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =?"; + } + @Override + protected String fetchHueQueriesNoStartdateYesEnddateSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =? AND mtime <= date(?)"; + } + @Override + protected String fetchHueQueriesYesStartdateNoEnddateSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =? AND mtime >= date(?)"; + + } + @Override + protected String fetchHueQueriesYesStartdateYesEnddateSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =? AND mtime >= date(?) AND mtime <= date(?)"; + + } + @Override + protected String fetchHueQueriesNoStartdateNoEnddateYesallUserSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'"; + } + @Override + protected String fetchHueQueriesNoStartdateYesEnddateYesallUserSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query' AND mtime <= date(?)"; + + } + @Override + protected String fetchHueQueriesYesStartdateNoEnddateYesallUserSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query' AND mtime >= date(?)"; + + } + @Override + protected String fetchHueQueriesYesStartdateYesEnddateYesallUserSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query' AND mtime >= date(?) AND mtime <= date(?)"; + + } + @Override + protected String fetchUserNameSql() { + return "select username from auth_user"; + } + + +} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/PostgressQuerySet.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/PostgressQuerySet.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/PostgressQuerySet.java deleted file mode 100644 index 83d32c7..0000000 --- a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/PostgressQuerySet.java +++ /dev/null @@ -1,22 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * <p/> - * http://www.apache.org/licenses/LICENSE-2.0 - * <p/> - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.savedqueryset; - - -public class PostgressQuerySet extends QuerySet { -} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/PostgressQuerySetHueDb.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/PostgressQuerySetHueDb.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/PostgressQuerySetHueDb.java new file mode 100644 index 0000000..a466cbc --- /dev/null +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/PostgressQuerySetHueDb.java @@ -0,0 +1,22 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * <p/> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p/> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.savedqueryset; + + +public class PostgressQuerySetHueDb extends QuerySetHueDb { +} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/QuerySet.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/QuerySet.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/QuerySet.java deleted file mode 100644 index c81d51a..0000000 --- a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/QuerySet.java +++ /dev/null @@ -1,134 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * <p/> - * http://www.apache.org/licenses/LICENSE-2.0 - * <p/> - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.savedqueryset; - -import java.sql.Connection; -import java.sql.PreparedStatement; -import java.sql.SQLException; - - -public abstract class QuerySet { - - - public PreparedStatement getUseridfromUserName(Connection connection, String username) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchuserIdfromUsernameSql()); - prSt.setString(1, username); - return prSt; - } - - public PreparedStatement getQueriesNoStartDateNoEndDate(Connection connection, int id) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateNoEnddateSql()); - prSt.setInt(1, id); - return prSt; - } - - public PreparedStatement getQueriesNoStartDateYesEndDate(Connection connection, int id, String enddate) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateYesEnddateSql()); - prSt.setInt(1, id); - prSt.setString(2, enddate); - return prSt; - } - - public PreparedStatement getQueriesYesStartDateNoEndDate(Connection connection, int id, String startdate) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateNoEnddateSql()); - prSt.setInt(1, id); - prSt.setString(2, startdate); - return prSt; - } - - public PreparedStatement getQueriesYesStartDateYesEndDate(Connection connection, int id, String startdate, String endate) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateYesEnddateSql()); - prSt.setInt(1, id); - prSt.setString(2, startdate); - prSt.setString(3, endate); - return prSt; - } - - /** - * for all user - */ - public PreparedStatement getQueriesNoStartDateNoEndDateAllUser(Connection connection) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateNoEnddateYesallUserSql()); - return prSt; - } - - public PreparedStatement getQueriesNoStartDateYesEndDateAllUser(Connection connection, String enddate) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateYesEnddateYesallUserSql()); - prSt.setString(1, enddate); - return prSt; - } - - public PreparedStatement getQueriesYesStartDateNoEndDateAllUser(Connection connection, String startdate) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateNoEnddateYesallUserSql()); - prSt.setString(1, startdate); - return prSt; - } - - public PreparedStatement getQueriesYesStartDateYesEndDateAllUser(Connection connection, String startdate, String endate) throws SQLException { - PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateYesEnddateYesallUserSql()); - prSt.setString(1, startdate); - prSt.setString(2, endate); - return prSt; - } - - - protected String fetchuserIdfromUsernameSql() { - return "select id from auth_user where username=?;"; - - } - - protected String fetchHueQueriesNoStartdateNoEnddateSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =?;"; - } - - protected String fetchHueQueriesNoStartdateYesEnddateSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =? AND mtime <= date(?);"; - } - - protected String fetchHueQueriesYesStartdateNoEnddateSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =? AND mtime >= date(?);"; - - } - - protected String fetchHueQueriesYesStartdateYesEnddateSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =? AND mtime >= date(?) AND mtime <= date(?);"; - - } - - protected String fetchHueQueriesNoStartdateNoEnddateYesallUserSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query';"; - } - - protected String fetchHueQueriesNoStartdateYesEnddateYesallUserSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query' AND mtime <= date(?);"; - - } - - protected String fetchHueQueriesYesStartdateNoEnddateYesallUserSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query' AND mtime >= date(?);"; - - } - - protected String fetchHueQueriesYesStartdateYesEnddateYesallUserSql() { - return "select data,name,owner_id from beeswax_savedquery where name!='My saved query' AND mtime >= date(?) AND mtime <= date(?);"; - - } - - -} http://git-wip-us.apache.org/repos/asf/ambari/blob/672fdf06/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/QuerySetHueDb.java ---------------------------------------------------------------------- diff --git a/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/QuerySetHueDb.java b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/QuerySetHueDb.java new file mode 100644 index 0000000..0f1a5f1 --- /dev/null +++ b/contrib/views/hueambarimigration/src/main/java/org/apache/ambari/view/huetoambarimigration/datasource/queryset/huequeryset/hive/savedqueryset/QuerySetHueDb.java @@ -0,0 +1,144 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * <p/> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p/> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.ambari.view.huetoambarimigration.datasource.queryset.huequeryset.hive.savedqueryset; + +import java.sql.Connection; +import java.sql.PreparedStatement; +import java.sql.SQLException; + + +public abstract class QuerySetHueDb { + + + public PreparedStatement getUseridfromUserName(Connection connection, String username) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchuserIdfromUsernameSql()); + prSt.setString(1, username); + return prSt; + } + + public PreparedStatement getQueriesNoStartDateNoEndDate(Connection connection, int id) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateNoEnddateSql()); + prSt.setInt(1, id); + return prSt; + } + + public PreparedStatement getQueriesNoStartDateYesEndDate(Connection connection, int id, String enddate) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateYesEnddateSql()); + prSt.setInt(1, id); + prSt.setString(2, enddate); + return prSt; + } + + public PreparedStatement getQueriesYesStartDateNoEndDate(Connection connection, int id, String startdate) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateNoEnddateSql()); + prSt.setInt(1, id); + prSt.setString(2, startdate); + return prSt; + } + + public PreparedStatement getQueriesYesStartDateYesEndDate(Connection connection, int id, String startdate, String endate) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateYesEnddateSql()); + prSt.setInt(1, id); + prSt.setString(2, startdate); + prSt.setString(3, endate); + return prSt; + } + + /** + * for all user + */ + public PreparedStatement getQueriesNoStartDateNoEndDateAllUser(Connection connection) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateNoEnddateYesallUserSql()); + return prSt; + } + + public PreparedStatement getQueriesNoStartDateYesEndDateAllUser(Connection connection, String enddate) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesNoStartdateYesEnddateYesallUserSql()); + prSt.setString(1, enddate); + return prSt; + } + + public PreparedStatement getQueriesYesStartDateNoEndDateAllUser(Connection connection, String startdate) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateNoEnddateYesallUserSql()); + prSt.setString(1, startdate); + return prSt; + } + + public PreparedStatement getQueriesYesStartDateYesEndDateAllUser(Connection connection, String startdate, String endate) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchHueQueriesYesStartdateYesEnddateYesallUserSql()); + prSt.setString(1, startdate); + prSt.setString(2, endate); + return prSt; + } + + public PreparedStatement getUserName(Connection connection, int id) throws SQLException { + PreparedStatement prSt = connection.prepareStatement(fetchUserNameSql()); + prSt.setInt(1, id); + return prSt; + } + + + protected String fetchuserIdfromUsernameSql() { + return "select id from auth_user where username=?;"; + + } + + protected String fetchHueQueriesNoStartdateNoEnddateSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =?;"; + } + + protected String fetchHueQueriesNoStartdateYesEnddateSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =? AND mtime <= date(?);"; + } + + protected String fetchHueQueriesYesStartdateNoEnddateSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =? AND mtime >= date(?);"; + + } + + protected String fetchHueQueriesYesStartdateYesEnddateSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query'and owner_id =? AND mtime >= date(?) AND mtime <= date(?);"; + + } + + protected String fetchHueQueriesNoStartdateNoEnddateYesallUserSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query';"; + } + + protected String fetchHueQueriesNoStartdateYesEnddateYesallUserSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query' AND mtime <= date(?);"; + + } + + protected String fetchHueQueriesYesStartdateNoEnddateYesallUserSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query' AND mtime >= date(?);"; + + } + + protected String fetchHueQueriesYesStartdateYesEnddateYesallUserSql() { + return "select data,name,owner_id from beeswax_savedquery where name!='My saved query' AND mtime >= date(?) AND mtime <= date(?);"; + + } + + protected String fetchUserNameSql() { + return "select username from auth_user where id = ?;"; + } + + +}
