Repository: ambari Updated Branches: refs/heads/branch-2.6 26ff188e2 -> 4fbe3c763
AMBARI-22213. "ambari-server upgrade" failed on db schema [Upgrade] (dlysnichenko) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/4fbe3c76 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/4fbe3c76 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/4fbe3c76 Branch: refs/heads/branch-2.6 Commit: 4fbe3c763bd2516b13cf32edc382f29eaedde34e Parents: 26ff188 Author: Lisnichenko Dmitro <dlysniche...@hortonworks.com> Authored: Thu Oct 12 13:52:15 2017 +0300 Committer: Lisnichenko Dmitro <dlysniche...@hortonworks.com> Committed: Thu Oct 12 13:52:15 2017 +0300 ---------------------------------------------------------------------- .../apache/ambari/server/orm/DBAccessorImpl.java | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/4fbe3c76/ambari-server/src/main/java/org/apache/ambari/server/orm/DBAccessorImpl.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/orm/DBAccessorImpl.java b/ambari-server/src/main/java/org/apache/ambari/server/orm/DBAccessorImpl.java index 20b991b..09316be 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/orm/DBAccessorImpl.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/orm/DBAccessorImpl.java @@ -1496,8 +1496,12 @@ public class DBAccessorImpl implements DBAccessor { */ @Override public void clearTable(String tableName) throws SQLException{ - String sqlQuery = "DELETE FROM " + convertObjectName(tableName); - executeQuery(sqlQuery); + if (tableExists(tableName)){ + String sqlQuery = "DELETE FROM " + convertObjectName(tableName); + executeQuery(sqlQuery); + } else { + LOG.warn("{} table doesn't exists, skipping", tableName); + } } /** @@ -1509,8 +1513,12 @@ public class DBAccessorImpl implements DBAccessor { */ @Override public void clearTableColumn(String tableName, String columnName, Object value) throws SQLException { - String sqlQuery = String.format("UPDATE %s SET %s = ?", convertObjectName(tableName), convertObjectName(columnName)); - executePreparedUpdate(sqlQuery, value); + if (tableExists(tableName)){ + String sqlQuery = String.format("UPDATE %s SET %s = ?", convertObjectName(tableName), convertObjectName(columnName)); + executePreparedUpdate(sqlQuery, value); + } else { + LOG.warn("{} table doesn't exists, skipping", tableName); + } } /**
