简柏林 / thingskit · Commits

Commit b8c8f57a82d3de7685fc5c889c0943b2e65bf280

Authored by Volodymyr Babak
1 parent c34fb5d9

Fixed dump for bigint

Inline Side-by-side
Showing 2 changed files with 5 additions and 1 deletions
@@ -224,7 +224,7 @@ public class CassandraDatabaseUpgradeService implements DatabaseUpgradeService { @@ -224,7 +224,7 @@ public class CassandraDatabaseUpgradeService implements DatabaseUpgradeService {
224 224
225 case "2.1.1": 225 case "2.1.1":
226 226
227 - log.info("Upgrading Cassandara DataBase from version {} to 2.1.2 ...", fromVersion); 227 + log.info("Upgrading Cassandra DataBase from version {} to 2.1.2 ...", fromVersion);
228 228
229 cluster.getSession(); 229 cluster.getSession();
230 230
@@ -147,6 +147,8 @@ public class CassandraDbHelper { @@ -147,6 +147,8 @@ public class CassandraDbHelper {
147 str = new Double(row.getDouble(index)).toString(); 147 str = new Double(row.getDouble(index)).toString();
148 } else if (type == DataType.cint()) { 148 } else if (type == DataType.cint()) {
149 str = new Integer(row.getInt(index)).toString(); 149 str = new Integer(row.getInt(index)).toString();
  150 + } else if (type == DataType.bigint()) {
  151 + str = new Long(row.getLong(index)).toString();
150 } else if (type == DataType.uuid()) { 152 } else if (type == DataType.uuid()) {
151 str = row.getUUID(index).toString(); 153 str = row.getUUID(index).toString();
152 } else if (type == DataType.timeuuid()) { 154 } else if (type == DataType.timeuuid()) {
@@ -193,6 +195,8 @@ public class CassandraDbHelper { @@ -193,6 +195,8 @@ public class CassandraDbHelper {
193 boundStatement.setDouble(column, Double.valueOf(value)); 195 boundStatement.setDouble(column, Double.valueOf(value));
194 } else if (type == DataType.cint()) { 196 } else if (type == DataType.cint()) {
195 boundStatement.setInt(column, Integer.valueOf(value)); 197 boundStatement.setInt(column, Integer.valueOf(value));
  198 + } else if (type == DataType.bigint()) {
  199 + boundStatement.setLong(column, Long.valueOf(value));
196 } else if (type == DataType.uuid()) { 200 } else if (type == DataType.uuid()) {
197 boundStatement.setUUID(column, UUID.fromString(value)); 201 boundStatement.setUUID(column, UUID.fromString(value));
198 } else if (type == DataType.timeuuid()) { 202 } else if (type == DataType.timeuuid()) {