11 test/FluentCassandra.Tests/CassandraDatabaseSetup.cs
View file
@@ -2,6 +2,7 @@
using System.Linq;
using FluentCassandra.Connections;
using FluentCassandra.Types;
using System.Collections.Generic;

namespace FluentCassandra
{
@@ -71,8 +72,14 @@ public CassandraDatabaseSetup(bool volitile = false)
keyspace.TryCreateColumnFamily<TimeUUIDType>("StandardTimeUUIDType");
keyspace.TryCreateColumnFamily<UTF8Type>("StandardUTF8Type");
keyspace.TryCreateColumnFamily<UUIDType>("StandardUUIDType");
keyspace.TryCreateColumnFamily<CompositeType<LongType, UTF8Type>>("StandardCompositeType");
keyspace.TryCreateColumnFamily<DynamicCompositeType>("StandardDynamicCompositeType");
keyspace.TryCreateColumnFamily(new CassandraColumnFamilySchema {
FamilyName = "StandardCompositeType",
ColumnNameType = CassandraType.CompositeType(new[] { CassandraType.AsciiType, CassandraType.DoubleType })
});
keyspace.TryCreateColumnFamily(new CassandraColumnFamilySchema {
FamilyName = "StandardDynamicCompositeType",
ColumnNameType = CassandraType.DynamicCompositeType(new Dictionary<char, CassandraType> { { 'a', CassandraType.AsciiType }, { 'd', CassandraType.DoubleType } })
});

Family = DB.GetColumnFamily<AsciiType>("Standard");
SuperFamily = DB.GetColumnFamily<AsciiType, AsciiType>("Super");
2 test/FluentCassandra.Tests/Types/CompositeTypeTest.cs
View file
@@ -97,7 +97,7 @@ public void JavaBytes_To_CompositeType_WithHints()

// act
var actual = new CompositeType();
actual.ComponentTypeHints = _compositeType.Select(t => t.GetType()).ToList();
actual.ComponentTypeHints = _compositeType.Select(t => new CassandraType(t.GetType().Name)).ToList();
actual.SetValueFromBigEndian(_javaByteOrder);

// assert