cloudstack-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sw...@apache.org
Subject [1/7] git commit: updated refs/heads/master to 22c6b47
Date Mon, 13 Jun 2016 13:53:38 GMT
Repository: cloudstack
Updated Branches:
  refs/heads/master 971c8a74e -> 22c6b4747


CLOUDSTACK-9409: Add role_id to cloud_usage.account

Adds role_id column to cloud_usage.account, fixes UsageDaoImpl to insert
Accounts with role_id from account table.

Signed-off-by: Rohit Yadav <rohit.yadav@shapeblue.com>


Project: http://git-wip-us.apache.org/repos/asf/cloudstack/repo
Commit: http://git-wip-us.apache.org/repos/asf/cloudstack/commit/fd67871a
Tree: http://git-wip-us.apache.org/repos/asf/cloudstack/tree/fd67871a
Diff: http://git-wip-us.apache.org/repos/asf/cloudstack/diff/fd67871a

Branch: refs/heads/master
Commit: fd67871a27dcb2b2a67e36e4f96ea1b0f07f0ede
Parents: 971c8a7
Author: Rohit Yadav <rohit.yadav@shapeblue.com>
Authored: Wed Jun 8 11:20:46 2016 +0900
Committer: Rohit Yadav <rohit.yadav@shapeblue.com>
Committed: Wed Jun 8 11:20:46 2016 +0900

----------------------------------------------------------------------
 .../src/com/cloud/upgrade/dao/Upgrade481to490.java       |  8 +++++++-
 engine/schema/src/com/cloud/usage/dao/UsageDaoImpl.java  | 11 ++++++-----
 2 files changed, 13 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cloudstack/blob/fd67871a/engine/schema/src/com/cloud/upgrade/dao/Upgrade481to490.java
----------------------------------------------------------------------
diff --git a/engine/schema/src/com/cloud/upgrade/dao/Upgrade481to490.java b/engine/schema/src/com/cloud/upgrade/dao/Upgrade481to490.java
index d1240ec..1c6ce38 100644
--- a/engine/schema/src/com/cloud/upgrade/dao/Upgrade481to490.java
+++ b/engine/schema/src/com/cloud/upgrade/dao/Upgrade481to490.java
@@ -103,10 +103,16 @@ public class Upgrade481to490 implements DbUpgrade {
                 s_logger.warn("cloud.account table already has the role_id column, skipping
altering table and migration of accounts");
                 return;
             } else {
-                throw new CloudRuntimeException("Unable to create column quota_calculated
in table cloud_usage.cloud_usage", e);
+                throw new CloudRuntimeException("Unable to create column role_id in table
cloud.account", e);
             }
         }
 
+        try (final PreparedStatement pstmt = conn.prepareStatement("ALTER TABLE `cloud_usage`.`account`
ADD COLUMN `role_id` bigint(20) unsigned AFTER `type`")) {
+            pstmt.executeUpdate();
+        } catch (SQLException e) {
+            throw new CloudRuntimeException("Unable to create column role_id in table cloud_usage.account",
e);
+        }
+
         migrateAccountsToDefaultRoles(conn);
 
         final Map<String, String> apiMap = PropertiesUtil.processConfigFile(new String[]
{ PropertiesUtil.getDefaultApiCommandsFileName() });

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/fd67871a/engine/schema/src/com/cloud/usage/dao/UsageDaoImpl.java
----------------------------------------------------------------------
diff --git a/engine/schema/src/com/cloud/usage/dao/UsageDaoImpl.java b/engine/schema/src/com/cloud/usage/dao/UsageDaoImpl.java
index 9c9ab0b..39f57df 100644
--- a/engine/schema/src/com/cloud/usage/dao/UsageDaoImpl.java
+++ b/engine/schema/src/com/cloud/usage/dao/UsageDaoImpl.java
@@ -49,7 +49,7 @@ public class UsageDaoImpl extends GenericDaoBase<UsageVO, Long> implements
Usage
     private static final String DELETE_ALL = "DELETE FROM cloud_usage";
     private static final String DELETE_ALL_BY_ACCOUNTID = "DELETE FROM cloud_usage WHERE
account_id = ?";
     private static final String DELETE_ALL_BY_INTERVAL = "DELETE FROM cloud_usage WHERE end_date
< DATE_SUB(CURRENT_DATE(), INTERVAL ? DAY)";
-    private static final String INSERT_ACCOUNT = "INSERT INTO cloud_usage.account (id, account_name,
type, domain_id, removed, cleanup_needed) VALUES (?,?,?,?,?,?)";
+    private static final String INSERT_ACCOUNT = "INSERT INTO cloud_usage.account (id, account_name,
type, role_id, domain_id, removed, cleanup_needed) VALUES (?,?,?,?,?,?,?)";
     private static final String INSERT_USER_STATS = "INSERT INTO cloud_usage.user_statistics
(id, data_center_id, account_id, public_ip_address, device_id, device_type, network_id, net_bytes_received,"
             + " net_bytes_sent, current_bytes_received, current_bytes_sent, agg_bytes_received,
agg_bytes_sent) VALUES (?,?,?,?,?,?,?,?,?,?, ?, ?, ?)";
 
@@ -113,16 +113,17 @@ public class UsageDaoImpl extends GenericDaoBase<UsageVO, Long>
implements Usage
                 pstmt.setLong(1, acct.getId());
                 pstmt.setString(2, acct.getAccountName());
                 pstmt.setShort(3, acct.getType());
-                pstmt.setLong(4, acct.getDomainId());
+                pstmt.setLong(4, acct.getRoleId());
+                pstmt.setLong(5, acct.getDomainId());
 
                 Date removed = acct.getRemoved();
                 if (removed == null) {
-                    pstmt.setString(5, null);
+                    pstmt.setString(6, null);
                 } else {
-                    pstmt.setString(5, DateUtil.getDateDisplayString(TimeZone.getTimeZone("GMT"),
acct.getRemoved()));
+                    pstmt.setString(6, DateUtil.getDateDisplayString(TimeZone.getTimeZone("GMT"),
acct.getRemoved()));
                 }
 
-                pstmt.setBoolean(6, acct.getNeedsCleanup());
+                pstmt.setBoolean(7, acct.getNeedsCleanup());
 
                 pstmt.addBatch();
             }


Mime
View raw message