Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

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

  • Loading branch information...
commit fa0ea23eebc9992f6da63af7aa54ac777664c5fc 1 parent 556bde7
@nberardi nberardi authored
View
5 src/Operations/GetColumnFamilyIndexedSlices.cs
@@ -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);
View
5 src/Operations/GetColumnFamilyRangeSlices.cs
@@ -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);
View
5 src/Operations/GetSuperColumnFamilyIndexedSlices.cs
@@ -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();
View
2  src/Operations/GetSuperColumnFamilyRangeSlices.cs
@@ -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);
Please sign in to comment.
Something went wrong with that request. Please try again.