modules/platforms/cpp/core-test/src/binary_identity_resolver_test.cpp - ignite - Git at Google

 /*
  * Licensed to the Apache Software Foundation (ASF) under one or more
  * contributor license agreements.  See the NOTICE file distributed with
  * this work for additional information regarding copyright ownership.
  * The ASF licenses this file to You under the Apache License, Version 2.0
  * (the "License"); you may not use this file except in compliance with
  * the License.  You may obtain a copy of the License at
  *
  *      http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */

 #include <sstream>

 #include <boost/test/unit_test.hpp>

 #include <ignite/common/utils.h>

 #include "ignite/cache/cache.h"
 #include "ignite/cache/query/query_cursor.h"
 #include "ignite/cache/query/query_sql_fields.h"
 #include "ignite/ignite.h"
 #include "ignite/ignition.h"

 #include "ignite/test_utils.h"
 #include "ignite/complex_type.h"


 using namespace boost::unit_test;

 using namespace ignite;
 using namespace ignite::cache;
 using namespace ignite::cache::query;
 using namespace ignite::common;
 using namespace ignite::binary;
 using namespace ignite::impl::interop;
 using namespace ignite::impl::binary;

 /**
  * Composite key class.
  */
 struct CompositeKey
 {
     /**
      * Default constructor.
      */
     CompositeKey() :
         str(),
         ts(),
         guid()
     {
         // No-op.
     }

     /**
      * Constructor.
      *
      * @param str String part.
      * @param ts Timestamp part.
      * @param guid Guid part.
      */
     CompositeKey(const std::string& str, const Timestamp& ts, const Guid& guid) :
         str(str),
         ts(ts),
         guid(guid)
     {
         // No-op.
     }

     /** String part. */
     std::string str;

     /** Timestamp. */
     Timestamp ts;

     /** Guid. */
     Guid guid;
 };

 /**
  * Simple composite key class.
  */
 struct CompositeKeySimple
 {
     /**
      * Default constructor.
      */
     CompositeKeySimple() :
         str(),
         ts(),
         i64(0)
     {
         // No-op.
     }

     /**
      * Constructor.
      *
      * @param str String part.
      * @param ts Timestamp part.
      * @param i64 Integer part.
      */
     CompositeKeySimple(const std::string& str, const Timestamp& ts, int64_t i64) :
         str(str),
         ts(ts),
         i64(i64)
     {
         // No-op.
     }

     /** String part. */
     std::string str;

     /** Timestamp. */
     Timestamp ts;

     /** Integer 64-bit. */
     int64_t i64;
 };

 struct TestUserClassBase
 {
     int32_t field;
 };

 struct DefaultHashing : TestUserClassBase {};

 namespace ignite
 {
     namespace binary
     {
         template<>
         struct BinaryType<DefaultHashing>
         {
             IGNITE_BINARY_GET_TYPE_ID_AS_HASH(DefaultHashing)
             IGNITE_BINARY_GET_TYPE_NAME_AS_IS(DefaultHashing)
             IGNITE_BINARY_GET_FIELD_ID_AS_HASH
             IGNITE_BINARY_IS_NULL_FALSE(DefaultHashing)
             IGNITE_BINARY_GET_NULL_DEFAULT_CTOR(DefaultHashing)

             static void Write(BinaryWriter& writer, const DefaultHashing& obj)
             {
                 writer.WriteInt32("field", obj.field);
             }

             static void Read(BinaryReader& reader, DefaultHashing& dst)
             {
                 dst.field = reader.ReadInt32("field");
             }
         };

         /**
          * Binary type definition for CompositeKey.
          */
         template<>
         struct BinaryType<CompositeKey>
         {
             IGNITE_BINARY_GET_TYPE_ID_AS_HASH(CompositeKey)
             IGNITE_BINARY_GET_TYPE_NAME_AS_IS(CompositeKey)
             IGNITE_BINARY_GET_FIELD_ID_AS_HASH
             IGNITE_BINARY_IS_NULL_FALSE(CompositeKey)
             IGNITE_BINARY_GET_NULL_DEFAULT_CTOR(CompositeKey)

             static void Write(BinaryWriter& writer, const CompositeKey& obj)
             {
                 writer.WriteString("str", obj.str);
                 writer.WriteTimestamp("ts", obj.ts);
                 writer.WriteGuid("guid", obj.guid);
             }

             static void Read(BinaryReader& reader, CompositeKey& dst)
             {
                 dst.str = reader.ReadString("str");
                 dst.ts = reader.ReadTimestamp("ts");
                 dst.guid = reader.ReadGuid("guid");
             }
         };

         /**
          * Binary type definition for CompositeKeySimple.
          */
         template<>
         struct BinaryType<CompositeKeySimple>
         {
             IGNITE_BINARY_GET_TYPE_ID_AS_HASH(CompositeKeySimple)
             IGNITE_BINARY_GET_TYPE_NAME_AS_IS(CompositeKeySimple)
             IGNITE_BINARY_GET_FIELD_ID_AS_HASH
             IGNITE_BINARY_IS_NULL_FALSE(CompositeKeySimple)
             IGNITE_BINARY_GET_NULL_DEFAULT_CTOR(CompositeKeySimple)

             static void Write(BinaryWriter& writer, const CompositeKeySimple& obj)
             {
                 writer.WriteString("str", obj.str);
                 writer.WriteTimestamp("ts", obj.ts);
                 writer.WriteInt64("i64", obj.i64);
             }

             static void Read(BinaryReader& reader, CompositeKeySimple& dst)
             {
                 dst.str = reader.ReadString("str");
                 dst.ts = reader.ReadTimestamp("ts");
                 dst.i64 = reader.ReadInt64("i64");
             }
         };
     }
 }

 /**
  * Test setup fixture.
  */
 struct BinaryIdentityResolverTestSuiteFixture
 {
     /**
      * Constructor.
      */
     BinaryIdentityResolverTestSuiteFixture()
     {
         // No-op.
     }

     /**
      * Destructor.
      */
     ~BinaryIdentityResolverTestSuiteFixture()
     {
         Ignition::StopAll(true);
     }
 };

 template<typename T>
 void FillMem(InteropMemory& mem, const T& value)
 {
     InteropOutputStream stream(&mem);
     BinaryWriterImpl writer(&stream, 0);

     writer.WriteObject<T>(value);

     stream.Synchronize();
 }

 template<typename T>
 int32_t RetrieveHashCode(const T& value)
 {
     InteropUnpooledMemory mem(1024);

     FillMem<T>(mem, value);

     BinaryObjectImpl obj(mem, 0, 0, 0);

     return obj.GetHashCode();
 }

 BOOST_FIXTURE_TEST_SUITE(BinaryIdentityResolverTestSuite, BinaryIdentityResolverTestSuiteFixture)

 BOOST_AUTO_TEST_CASE(GetDataHashCode)
 {
     int8_t data1[] = { 0 };
     int8_t data2[] = { 0, 0, 0, 0 };
     int8_t data3[] = { 0, 0, 0, 0, 0, 0, 0, 0, 0, 0 };
     int8_t data4[] = { 1 };
     int8_t data5[] = { -1 };
     int8_t data6[] = { 0, 1, 2, 3, 4, 5, 6, 7, 8, 9 };
     int8_t data7[] = { 1, 2, 3, 4, 5, 6, 7, 8, 9, 0 };
     uint8_t data8[] = { 0xFF };
     uint8_t data9[] = { 0xFF, 0xFF, 0xFF, 0xFF };

     BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data1, sizeof(data1)), 0x0000001F);
     BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data2, sizeof(data2)), 0x000e1781);
     BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data3, sizeof(data3)), 0x94E4B2C1);
     BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data4, sizeof(data4)), 0x00000020);
     BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data5, sizeof(data5)), 0x0000001E);
     BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data6, sizeof(data6)), 0x9EBADAC6);
     BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data7, sizeof(data7)), 0xC5D38B5C);
     BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data8, sizeof(data8)), 0x0000001E);
     BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data9, sizeof(data9)), 0x000D9F41);
 }

 BOOST_AUTO_TEST_CASE(IdentityEquilityWithGuid)
 {
 #ifdef IGNITE_TESTS_32
     Ignite grid = ignite_test::StartNode("cache-identity-32.xml");
 #else
     Ignite grid = ignite_test::StartNode("cache-identity.xml");
 #endif

     CompositeKey key("Key String", Timestamp(123851, 562304134), Guid(0x4A950C6206FE4502, 0xAC06145097E56F02));
     int32_t value = 12321;

     Cache<CompositeKey, int32_t> cache = grid.GetOrCreateCache<CompositeKey, int32_t>("cache1");

     SqlFieldsQuery qry("INSERT INTO Integer (str, ts, guid, _val) VALUES (?, ?, ?, ?)");

     qry.AddArgument(key.str);
     qry.AddArgument(key.ts);
     qry.AddArgument(key.guid);
     qry.AddArgument(value);

     cache.Query(qry);

     int32_t realValue = cache.Get(key);

     BOOST_CHECK_EQUAL(value, realValue);
 }

 BOOST_AUTO_TEST_CASE(IdentityEquilityWithoutGuid)
 {
 #ifdef IGNITE_TESTS_32
     Ignite grid = ignite_test::StartNode("cache-identity-32.xml");
 #else
     Ignite grid = ignite_test::StartNode("cache-identity.xml");
 #endif

     CompositeKeySimple key("Lorem ipsum", Timestamp(112460, 163002155), 1337);
     int32_t value = 42;

     Cache<CompositeKeySimple, int32_t> cache = grid.GetOrCreateCache<CompositeKeySimple, int32_t>("cache2");

     SqlFieldsQuery qry("INSERT INTO Integer (str, ts, i64, _val) VALUES (?, ?, ?, ?)");

     qry.AddArgument(key.str);
     qry.AddArgument(key.ts);
     qry.AddArgument(key.i64);
     qry.AddArgument(value);

     cache.Query(qry);

     int32_t realValue = cache.Get(key);

     BOOST_CHECK_EQUAL(value, realValue);
 }

 BOOST_AUTO_TEST_CASE(TestDefaultHashing)
 {
     DefaultHashing val;
     val.field = 1337;

     BOOST_CHECK_EQUAL(RetrieveHashCode(val), 0x01F91B0E);
 }

 BOOST_AUTO_TEST_SUITE_END()
	/*
	* Licensed to the Apache Software Foundation (ASF) under one or more
	* contributor license agreements. See the NOTICE file distributed with
	* this work for additional information regarding copyright ownership.
	* The ASF licenses this file to You under the Apache License, Version 2.0
	* (the "License"); you may not use this file except in compliance with
	* the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/

	#include <sstream>

	#include <boost/test/unit_test.hpp>

	#include <ignite/common/utils.h>

	#include "ignite/cache/cache.h"
	#include "ignite/cache/query/query_cursor.h"
	#include "ignite/cache/query/query_sql_fields.h"
	#include "ignite/ignite.h"
	#include "ignite/ignition.h"

	#include "ignite/test_utils.h"
	#include "ignite/complex_type.h"


	using namespace boost::unit_test;

	using namespace ignite;
	using namespace ignite::cache;
	using namespace ignite::cache::query;
	using namespace ignite::common;
	using namespace ignite::binary;
	using namespace ignite::impl::interop;
	using namespace ignite::impl::binary;

	/**
	* Composite key class.
	*/
	struct CompositeKey
	{
	/**
	* Default constructor.
	*/
	CompositeKey() :
	str(),
	ts(),
	guid()
	{
	// No-op.
	}

	/**
	* Constructor.
	*
	* @param str String part.
	* @param ts Timestamp part.
	* @param guid Guid part.
	*/
	CompositeKey(const std::string& str, const Timestamp& ts, const Guid& guid) :
	str(str),
	ts(ts),
	guid(guid)
	{
	// No-op.
	}

	/** String part. */
	std::string str;

	/** Timestamp. */
	Timestamp ts;

	/** Guid. */
	Guid guid;
	};

	/**
	* Simple composite key class.
	*/
	struct CompositeKeySimple
	{
	/**
	* Default constructor.
	*/
	CompositeKeySimple() :
	str(),
	ts(),
	i64(0)
	{
	// No-op.
	}

	/**
	* Constructor.
	*
	* @param str String part.
	* @param ts Timestamp part.
	* @param i64 Integer part.
	*/
	CompositeKeySimple(const std::string& str, const Timestamp& ts, int64_t i64) :
	str(str),
	ts(ts),
	i64(i64)
	{
	// No-op.
	}

	/** String part. */
	std::string str;

	/** Timestamp. */
	Timestamp ts;

	/** Integer 64-bit. */
	int64_t i64;
	};

	struct TestUserClassBase
	{
	int32_t field;
	};

	struct DefaultHashing : TestUserClassBase {};

	namespace ignite
	{
	namespace binary
	{
	template<>
	struct BinaryType<DefaultHashing>
	{
	IGNITE_BINARY_GET_TYPE_ID_AS_HASH(DefaultHashing)
	IGNITE_BINARY_GET_TYPE_NAME_AS_IS(DefaultHashing)
	IGNITE_BINARY_GET_FIELD_ID_AS_HASH
	IGNITE_BINARY_IS_NULL_FALSE(DefaultHashing)
	IGNITE_BINARY_GET_NULL_DEFAULT_CTOR(DefaultHashing)

	static void Write(BinaryWriter& writer, const DefaultHashing& obj)
	{
	writer.WriteInt32("field", obj.field);
	}

	static void Read(BinaryReader& reader, DefaultHashing& dst)
	{
	dst.field = reader.ReadInt32("field");
	}
	};

	/**
	* Binary type definition for CompositeKey.
	*/
	template<>
	struct BinaryType<CompositeKey>
	{
	IGNITE_BINARY_GET_TYPE_ID_AS_HASH(CompositeKey)
	IGNITE_BINARY_GET_TYPE_NAME_AS_IS(CompositeKey)
	IGNITE_BINARY_GET_FIELD_ID_AS_HASH
	IGNITE_BINARY_IS_NULL_FALSE(CompositeKey)
	IGNITE_BINARY_GET_NULL_DEFAULT_CTOR(CompositeKey)

	static void Write(BinaryWriter& writer, const CompositeKey& obj)
	{
	writer.WriteString("str", obj.str);
	writer.WriteTimestamp("ts", obj.ts);
	writer.WriteGuid("guid", obj.guid);
	}

	static void Read(BinaryReader& reader, CompositeKey& dst)
	{
	dst.str = reader.ReadString("str");
	dst.ts = reader.ReadTimestamp("ts");
	dst.guid = reader.ReadGuid("guid");
	}
	};

	/**
	* Binary type definition for CompositeKeySimple.
	*/
	template<>
	struct BinaryType<CompositeKeySimple>
	{
	IGNITE_BINARY_GET_TYPE_ID_AS_HASH(CompositeKeySimple)
	IGNITE_BINARY_GET_TYPE_NAME_AS_IS(CompositeKeySimple)
	IGNITE_BINARY_GET_FIELD_ID_AS_HASH
	IGNITE_BINARY_IS_NULL_FALSE(CompositeKeySimple)
	IGNITE_BINARY_GET_NULL_DEFAULT_CTOR(CompositeKeySimple)

	static void Write(BinaryWriter& writer, const CompositeKeySimple& obj)
	{
	writer.WriteString("str", obj.str);
	writer.WriteTimestamp("ts", obj.ts);
	writer.WriteInt64("i64", obj.i64);
	}

	static void Read(BinaryReader& reader, CompositeKeySimple& dst)
	{
	dst.str = reader.ReadString("str");
	dst.ts = reader.ReadTimestamp("ts");
	dst.i64 = reader.ReadInt64("i64");
	}
	};
	}
	}

	/**
	* Test setup fixture.
	*/
	struct BinaryIdentityResolverTestSuiteFixture
	{
	/**
	* Constructor.
	*/
	BinaryIdentityResolverTestSuiteFixture()
	{
	// No-op.
	}

	/**
	* Destructor.
	*/
	~BinaryIdentityResolverTestSuiteFixture()
	{
	Ignition::StopAll(true);
	}
	};

	template<typename T>
	void FillMem(InteropMemory& mem, const T& value)
	{
	InteropOutputStream stream(&mem);
	BinaryWriterImpl writer(&stream, 0);

	writer.WriteObject<T>(value);

	stream.Synchronize();
	}

	template<typename T>
	int32_t RetrieveHashCode(const T& value)
	{
	InteropUnpooledMemory mem(1024);

	FillMem<T>(mem, value);

	BinaryObjectImpl obj(mem, 0, 0, 0);

	return obj.GetHashCode();
	}

	BOOST_FIXTURE_TEST_SUITE(BinaryIdentityResolverTestSuite, BinaryIdentityResolverTestSuiteFixture)

	BOOST_AUTO_TEST_CASE(GetDataHashCode)
	{
	int8_t data1[] = { 0 };
	int8_t data2[] = { 0, 0, 0, 0 };
	int8_t data3[] = { 0, 0, 0, 0, 0, 0, 0, 0, 0, 0 };
	int8_t data4[] = { 1 };
	int8_t data5[] = { -1 };
	int8_t data6[] = { 0, 1, 2, 3, 4, 5, 6, 7, 8, 9 };
	int8_t data7[] = { 1, 2, 3, 4, 5, 6, 7, 8, 9, 0 };
	uint8_t data8[] = { 0xFF };
	uint8_t data9[] = { 0xFF, 0xFF, 0xFF, 0xFF };

	BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data1, sizeof(data1)), 0x0000001F);
	BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data2, sizeof(data2)), 0x000e1781);
	BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data3, sizeof(data3)), 0x94E4B2C1);
	BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data4, sizeof(data4)), 0x00000020);
	BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data5, sizeof(data5)), 0x0000001E);
	BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data6, sizeof(data6)), 0x9EBADAC6);
	BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data7, sizeof(data7)), 0xC5D38B5C);
	BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data8, sizeof(data8)), 0x0000001E);
	BOOST_CHECK_EQUAL(BinaryUtils::GetDataHashCode(data9, sizeof(data9)), 0x000D9F41);
	}

	BOOST_AUTO_TEST_CASE(IdentityEquilityWithGuid)
	{
	#ifdef IGNITE_TESTS_32
	Ignite grid = ignite_test::StartNode("cache-identity-32.xml");
	#else
	Ignite grid = ignite_test::StartNode("cache-identity.xml");
	#endif

	CompositeKey key("Key String", Timestamp(123851, 562304134), Guid(0x4A950C6206FE4502, 0xAC06145097E56F02));
	int32_t value = 12321;

	Cache<CompositeKey, int32_t> cache = grid.GetOrCreateCache<CompositeKey, int32_t>("cache1");

	SqlFieldsQuery qry("INSERT INTO Integer (str, ts, guid, _val) VALUES (?, ?, ?, ?)");

	qry.AddArgument(key.str);
	qry.AddArgument(key.ts);
	qry.AddArgument(key.guid);
	qry.AddArgument(value);

	cache.Query(qry);

	int32_t realValue = cache.Get(key);

	BOOST_CHECK_EQUAL(value, realValue);
	}

	BOOST_AUTO_TEST_CASE(IdentityEquilityWithoutGuid)
	{
	#ifdef IGNITE_TESTS_32
	Ignite grid = ignite_test::StartNode("cache-identity-32.xml");
	#else
	Ignite grid = ignite_test::StartNode("cache-identity.xml");
	#endif

	CompositeKeySimple key("Lorem ipsum", Timestamp(112460, 163002155), 1337);
	int32_t value = 42;

	Cache<CompositeKeySimple, int32_t> cache = grid.GetOrCreateCache<CompositeKeySimple, int32_t>("cache2");

	SqlFieldsQuery qry("INSERT INTO Integer (str, ts, i64, _val) VALUES (?, ?, ?, ?)");

	qry.AddArgument(key.str);
	qry.AddArgument(key.ts);
	qry.AddArgument(key.i64);
	qry.AddArgument(value);

	cache.Query(qry);

	int32_t realValue = cache.Get(key);

	BOOST_CHECK_EQUAL(value, realValue);
	}

	BOOST_AUTO_TEST_CASE(TestDefaultHashing)
	{
	DefaultHashing val;
	val.field = 1337;

	BOOST_CHECK_EQUAL(RetrieveHashCode(val), 0x01F91B0E);
	}

	BOOST_AUTO_TEST_SUITE_END()