Permalink
Browse files

updated other opperations with suffered from the same error as issue #61

  • Loading branch information...
1 parent 556bde7 commit fa0ea23eebc9992f6da63af7aa54ac777664c5fc @nberardi nberardi committed Sep 6, 2012
@@ -1,6 +1,7 @@
using System;
using System.Collections.Generic;
using System.Linq;
+using FluentCassandra.Types;
namespace FluentCassandra.Operations
{
@@ -36,7 +37,9 @@ private IEnumerable<FluentColumnFamily> GetFamilies(BaseCassandraColumnFamily co
foreach (var result in output)
{
- var r = new FluentColumnFamily(result.Key, columnFamily.FamilyName, columnFamily.GetSchema(), result.Columns.Select(col => {
+ var key = CassandraObject.GetCassandraObjectFromDatabaseByteArray(result.Key, schema.KeyValueType);
+
+ var r = new FluentColumnFamily(key, columnFamily.FamilyName, columnFamily.GetSchema(), result.Columns.Select(col => {
return Helper.ConvertColumnToFluentColumn(col.Column, schema);
}));
columnFamily.Context.Attach(r);
@@ -1,6 +1,7 @@
using System;
using System.Collections.Generic;
using System.Linq;
+using FluentCassandra.Types;
namespace FluentCassandra.Operations
{
@@ -32,7 +33,9 @@ private IEnumerable<FluentColumnFamily> GetFamilies(BaseCassandraColumnFamily co
foreach (var result in output)
{
- var r = new FluentColumnFamily(result.Key, columnFamily.FamilyName, columnFamily.GetSchema(), result.Columns.Select(col => {
+ var key = CassandraObject.GetCassandraObjectFromDatabaseByteArray(result.Key, schema.KeyValueType);
+
+ var r = new FluentColumnFamily(key, columnFamily.FamilyName, columnFamily.GetSchema(), result.Columns.Select(col => {
return Helper.ConvertColumnToFluentColumn(col.Column, schema);
}));
columnFamily.Context.Attach(r);
@@ -1,6 +1,7 @@
using System;
using System.Collections.Generic;
using System.Linq;
+using FluentCassandra.Types;
namespace FluentCassandra.Operations
{
@@ -31,7 +32,9 @@ public override IEnumerable<FluentSuperColumnFamily> Execute()
foreach (var result in output)
{
- var r = new FluentSuperColumnFamily(result.Key, ColumnFamily.FamilyName, ColumnFamily.GetSchema(), result.Columns.Select(col => {
+ var key = CassandraObject.GetCassandraObjectFromDatabaseByteArray(result.Key, schema.KeyValueType);
+
+ var r = new FluentSuperColumnFamily(key, ColumnFamily.FamilyName, ColumnFamily.GetSchema(), result.Columns.Select(col => {
var superCol = Helper.ConvertSuperColumnToFluentSuperColumn(col.Super_column, schema);
ColumnFamily.Context.Attach(superCol);
superCol.MutationTracker.Clear();
@@ -30,7 +30,7 @@ public override IEnumerable<FluentSuperColumnFamily> Execute()
foreach (var result in output)
{
- var key = CassandraObject.GetCassandraObjectFromDatabaseByteArray(result.Key, schema.KeyValueType);
+ var key = CassandraObject.GetCassandraObjectFromDatabaseByteArray(result.Key, schema.KeyValueType);
var r = new FluentSuperColumnFamily(key, ColumnFamily.FamilyName, schema, result.Columns.Select(col => {
var superCol = Helper.ConvertSuperColumnToFluentSuperColumn(col.Super_column, schema);

0 comments on commit fa0ea23

Please sign in to comment.