Establish the connection

When you want to start an interaction with the storage on a server, you'll pretty much always use the functions detailed on this page. We put them into our 'init' function.

Inside the main function, we will add the call to init() with the necessary error handling.

Tutorial.cpp – main function

Tutorial.cs – main function

WDomain* pDomain;

if(S_OK != init(pDomain, strServerAddress, usServerPort, guidDomainId, ulStorageId))
{
	printf("init failed\n");
	return -1;
}

WDomain pDomain;

if(0 != init(out pDomain, strServerAddress, usServerPort, guidDomainId, ulStorageId))
{
	Console.WriteLine("init failed");
	return;
}

We always start with a call to InitializeThreadInitializeThread. This will load and initialize the libraries needed to work with DataFS and DataFSAccess.

init.cpp

init.cs

#include "pch.h"

HRESULT init(WDomain*& pDomain, const wchar_t* strServerAddress, UINT16 usServerPort, const GUID& guidDomainId, UINT32 ulStorageId)
{
	// load libraries and initialize thread
	InitializeThread();

public static int init(out WDomain pDomain, string strServerAddress, UInt16 usServerPort, Guid guidDomainId, UInt32 ulStorageId)
{
	// load libraries and initialize thread
	ThreadInit.InitializeThread();

Next, we will createcreate the connection object and initializeinitialize it.

	// build connection object
	Connection* pConnection = Connection_Create();

	pConnection->Initialize(&guidDomainId);

	// build connection object
	Connection pConnection = Connection.Create();

	pConnection.Initialize(guidDomainId);

After that, we establish the connectionestablish the connection. As you can see, the third parameter is NULLnull because, for this tutorial, our connection is unencrypted.

	// connect to server
	pConnection->Connect(strServerAddress, usServerPort, NULL);

	// connect to server
	pConnection.Connect(strServerAddress, usServerPort, null);

Now, we are ready to connect to the storageconnect to the storage with "QueryStorage". The second parameter is set to false because don't want to register an event clientevent client for now.

	// connect to storage
	pConnection->QueryStorage(ulStorageId, false);

	// connect to storage
	pConnection.QueryStorage(ulStorageId, false, null);

Then we can createcreate the domain object and initializeinitialize it.

	// build domain object
	pDomain = Domain_Create();

	pDomain->Initialize(pConnection, 0);

	// build domain object
	pDomain = WDomain.Create();

	pDomain.Initialize(pConnection, 0);

Finally, we are ready to call "Bind", which initialized the classes defined in DADL with data from the domain's schema. See this pagethis page for further information.

	// bind to schema
	AccessDefinition::Bind(pDomain);

	return S_OK;
}

	// bind to schema
	AccessDefinition.Bind(pDomain);

	return 0;
}

After that, we're technically ready to work with our data, but none exists yet. We'll look at how to uninitialize the connection first of all.

Final code

Our whole 'init' function with correct error handling would look something like this:

init.cpp

init.cs

#include "pch.h"

HRESULT init(Connection*& pConnection, WDomain*& pDomain, const wchar_t* strServerAddress, UINT16 usServerPort, const GUID& guidDomainId, UINT32 ulStorageId)
{
	HRESULT hRes;

	// load libraries and initialize thread
	InitializeThread();

	// build connection object
	pConnection = Connection_Create();

	if(FAILED(hRes = pConnection->Initialize(&guidDomainId)))
	{
		printf("Initialize connection failed (0x%x)\n", hRes);
		Connection_Destroy(pConnection);
		UninitializeThread();
		return E_FAIL;
	}

	// connect to server
	if(FAILED(hRes = pConnection->Connect(strServerAddress, usServerPort, NULL)))
	{
		printf("Connect failed (0x%x)\n", hRes);
		pConnection->Uninitialize();
		Connection_Destroy(pConnection);
		UninitializeThread();
		return E_FAIL;
	}

	// connect to storage
	if(FAILED(hRes = pConnection->QueryStorage(ulStorageId, false)))
	{
		printf("QueryStorage failed (0x%x)\n", hRes);
		pConnection->DisconnectAll();
		pConnection->Uninitialize();
		Connection_Destroy(pConnection);
		UninitializeThread();
		return E_FAIL;
	}

	// build domain object
	pDomain = Domain_Create();

	if(FAILED(hRes = pDomain->Initialize(pConnection, 0)))
	{
		printf("Initialize failed (0x%x)\n", hRes);
		Domain_Destroy(pDomain);
		pConnection->ReleaseAllStorages();
		pConnection->DisconnectAll();
		pConnection->Uninitialize();
		Connection_Destroy(pConnection);
		UninitializeThread();
		return E_FAIL;
	}

	// bind to schema
	if(FAILED(hRes = AccessDefinition::Bind(pDomain)))
	{
		printf("Bind failed (0x%x)\n", hRes);
		pDomain->Uninitialize();
		Domain_Destroy(pDomain);
		pConnection->ReleaseAllStorages();
		pConnection->DisconnectAll();
		pConnection->Uninitialize();
		Connection_Destroy(pConnection);
		UninitializeThread();
		return E_FAIL;
	}

	return S_OK;
}

using System;
using DataFSAccess;

namespace TutorialCs
{
	partial class Tutorial
	{
		public static int init(out WDomain pDomain, string strServerAddress, UInt16 usServerPort, Guid guidDomainId, UInt32 ulStorageId)
		{
			int hRes;

			// load libraries and initialize thread
			ThreadInit.InitializeThread();

			// build connection object
			Connection pConnection = Connection.Create();

			if(0 > (hRes = pConnection.Initialize(guidDomainId)))
			{
				Console.WriteLine("Initialize connection failed (0x{0:x})", hRes);
				Connection.Destroy(pConnection);
				ThreadInit.UninitializeThread();
				pDomain = null;
				return -1;
			}

			// connect to server
			if(0 > (hRes = pConnection.Connect(strServerAddress, usServerPort, null, null)))
			{
				Console.WriteLine("Connect failed (0x{0:x})", hRes);
				pConnection.Uninitialize();
				Connection.Destroy(pConnection);
				ThreadInit.UninitializeThread();
				pDomain = null;
				return -1;
			}

			// connect to storage
			if(0 > (hRes = pConnection.QueryStorage(ulStorageId, false, null)))
			{
				Console.WriteLine("QueryStorage failed (0x{0:x})", hRes);
				pConnection.DisconnectAll();
				pConnection.Uninitialize();
				Connection.Destroy(pConnection);
				ThreadInit.UninitializeThread();
				pDomain = null;
				return -1;
			}

			// build domain object
			pDomain = WDomain.Create();

			if (0 > (hRes = pDomain.Initialize(pConnection, 0)))
			{
				Console.WriteLine("Initialize domain failed (0x{0:x})", hRes);
				WDomain.Destroy(pDomain);
				pConnection.ReleaseStorage(ulStorageId);
				pConnection.DisconnectAll();
				pConnection.Uninitialize();
				Connection.Destroy(pConnection);
				ThreadInit.UninitializeThread();
				pDomain = null;
				return -1;
			}

			// bind to schema
			if (0 > (hRes = AccessDefinition.Bind(pDomain)))
			{
				Console.WriteLine("Bind failed (0x{0:x})", hRes);
				pDomain.Uninitialize();
				WDomain.Destroy(pDomain);
				pConnection.ReleaseStorage(ulStorageId);
				pConnection.DisconnectAll();
				pConnection.Uninitialize();
				Connection.Destroy(pConnection);
				ThreadInit.UninitializeThread();
				pDomain = null;
				return -1;
			}

			return 0;
		}
	}
}