Got a good working sample. Now to clean up the CLR host and allow some configuration from external files.

Author: debugthings

clr_host/ClrHost.cpp

@@ -4,9 +4,13 @@
 const wchar_t *CClrHost::AppDomainManagerAssembly = L"mysql_managed_interface, Version=1.0.0.0, PublicKeyToken=71c4a5d4270bd29c";
 const wchar_t *CClrHost::AppDomainManagerType = L"mysql_managed_interface.MySQLHostManager";
 
+bool g_CLRHasBeenLoaded = false;
+
 /// <summary>
 ///     Initialize the host
 /// </summary>
+
+
 CClrHost::CClrHost() : m_started(false), m_pClr(NULL), m_pClrControl(NULL)
 {
 	return;
@@ -36,15 +40,15 @@ CClrHost::~CClrHost()
 #pragma warning( disable : 4996 )
 HRESULT CClrHost::FinalConstruct()
 {
-	// load the CLR into the process
+	//load the CLR into the process
 	return CorBindToRuntimeEx(NULL,
 		NULL,
 		0,
 		CLSID_CLRRuntimeHost,
 		IID_ICLRRuntimeHost,
 		reinterpret_cast<LPVOID *>(&m_pClr));
 
-	//// load the CLR into the process
+	// load the CLR into the process
 	//ICLRMetaHost       *pMetaHost = NULL;
 	//ICLRMetaHostPolicy *pMetaHostPolicy = NULL;
 	//ICLRDebugging      *pCLRDebugging = NULL;
@@ -60,22 +64,41 @@ HRESULT CClrHost::FinalConstruct()
 	//IEnumUnknown * pRtEnum = NULL;
 	//ICLRRuntimeInfo *info = NULL;
 	//ULONG fetched = 0;
+	//pMetaHost->EnumerateLoadedRuntimes(GetCurrentProcess(), &pRtEnum);
+	//while ((hr = pRtEnum->Next(1, (IUnknown **)&info, &fetched)) == S_OK && fetched > 0)
+	//{
+	//	WCHAR strName[128];
+	//	ZeroMemory(strName, sizeof(strName));
+	//	DWORD len = 128;
+	//	info->GetVersionString(strName, &len);
+	//	hr = info->GetInterface(CLSID_CLRRuntimeHost,
+	//		IID_ICLRRuntimeHost,
+	//		reinterpret_cast<LPVOID *>(&m_pClr));
+	//	if (!SUCCEEDED(hr))
+	//		printf("hr failed....");
+
+	//}
+	//pRtEnum->Release();
+	//pRtEnum = NULL;
+
 	//pMetaHost->EnumerateInstalledRuntimes(&pRtEnum);
 	//while ((hr = pRtEnum->Next(1, (IUnknown **)&info, &fetched)) == S_OK && fetched > 0)
 	//{
 	//	WCHAR strName[128];
 	//	ZeroMemory(strName, sizeof(strName));
 	//	DWORD len = 128;
 	//	info->GetVersionString(strName, &len);
-	//	hr = info->GetInterface(CLSID_CLRRuntimeHost, 
-	//		IID_ICLRRuntimeHost, 
+	//	hr = info->GetInterface(CLSID_CLRRuntimeHost,
+	//		IID_ICLRRuntimeHost,
 	//		reinterpret_cast<LPVOID *>(&m_pClr));
 	//	if (!SUCCEEDED(hr))
 	//		printf("hr failed....");
-	//	
+
 	//}
 	//pRtEnum->Release();
-	//return S_OK;
+
+
+	return S_OK;
 }
 
 /// <summary>
@@ -150,14 +173,18 @@ STDMETHODIMP CClrHost::raw_Start()
 	// we should have bound to the runtime, but not yet started it upon entry
 	_ASSERTE(m_pClr != NULL);
 	_ASSERTE(!m_started);
+
 	if (m_pClr == NULL)
 		return E_FAIL;
 
 	// get the CLR control object
 	HRESULT hrClrControl = m_pClr->GetCLRControl(&m_pClrControl);
 	if (FAILED(hrClrControl))
 		return hrClrControl;
-	
+
+	// set ourselves up as the host control
+	HRESULT hrHostControl = m_pClr->SetHostControl(static_cast<IHostControl *>(this));
+
 	// get the host protection manager
 	ICLRHostProtectionManager *pHostProtectionManager = NULL;
 	HRESULT hrGetProtectionManager = m_pClrControl->GetCLRManager(
@@ -174,27 +201,20 @@ STDMETHODIMP CClrHost::raw_Start()
 	if (FAILED(hrHostProtection))
 		return hrHostProtection;
 
-	// set ourselves up as the host control
-	HRESULT hrHostControl = m_pClr->SetHostControl(static_cast<IHostControl *>(this));
-	if (FAILED(hrHostControl))
-		return hrHostControl;
 
 	// setup the AppDomainManager
 	HRESULT hrSetAdm = m_pClrControl->SetAppDomainManagerType(AppDomainManagerAssembly, AppDomainManagerType);
 	if (FAILED(hrSetAdm))
 		return hrSetAdm;
 
-	
-
-	
+	// mark as started
+	m_started = true;
 
 	// finally, start the runtime
 	HRESULT hrStart = m_pClr->Start();
 	if (FAILED(hrStart))
 		return hrStart;
 
-	// mark as started
-	m_started = true;
 	return S_OK;
 }
 
@@ -205,7 +225,6 @@ STDMETHODIMP CClrHost::raw_Start()
 STDMETHODIMP CClrHost::raw_Stop()
 {
 	_ASSERTE(m_started);
-
 	// first send a Dispose call to the managed hosts
 	for (AppDomainManagerMap::iterator iAdm = m_appDomainManagers.begin(); iAdm != m_appDomainManagers.end(); iAdm++)
 		iAdm->second->raw_Dispose();

clr_host/ClrHost.h

@@ -43,8 +43,8 @@ class ATL_NO_VTABLE CClrHost : public CComObjectRootEx<CComSingleThreadModel>,
 
 	// IHostControl
 public:
-	STDMETHODIMP GetHostManager(const IID &riid,  void **ppvObject);
-	STDMETHODIMP SetAppDomainManager(DWORD dwAppDomainId,  IUnknown *pUnkAppDomainManager);
+	STDMETHODIMP GetHostManager(const IID &riid, void **ppvObject);
+	STDMETHODIMP SetAppDomainManager(DWORD dwAppDomainId, IUnknown *pUnkAppDomainManager);
 
 	// IUnmanagedHost
 public:

clr_host/stdafx.h

@@ -31,7 +31,12 @@
 #include <comdef.h>
 #include <tchar.h>
 #include <mscoree.h>
+#ifdef DEBUG
+#import "Debug/mysql_managed_interface.tlb" no_namespace
+#else
 #import "Release/mysql_managed_interface.tlb" no_namespace
+#endif
+
 #pragma warning (pop)
 #include <metahost.h>
 #pragma comment(lib, "mscoree.lib")

udf_example.c

@@ -84,23 +84,15 @@ extern "C"
 	longlong myfunc_int(UDF_INIT *initid, UDF_ARGS *args, char *is_null,
 		char *error);
 	void myfunc_int_deinit(UDF_INIT *initid);
-	int RunApplication(IUnmanagedHostPtr &pClr, char *input);
 
-	int RunApplication(IUnmanagedHostPtr &pClr, char *input)
+	longlong RunApplication(IUnmanagedHostPtr &pClr, longlong input);
+
+	longlong RunApplication(IUnmanagedHostPtr &pClr, longlong input)
 	{
 		// Get the default managed host
 		IManagedHostPtr pManagedHost = pClr->DefaultManagedHost;
 
-		// create a new AppDomain
-		_bstr_t name(L"Second AppDomain");
-		DWORD id = pManagedHost->CreateAppDomain(name);
-
-		// get its host, and print to the screen
-		IManagedHostPtr pSecondManagedHost = pClr->GetManagedHost(id);
-		//pSecondManagedHost->Write(_bstr_t(L"Hello, World."));
-		pSecondManagedHost->Run(_bstr_t(input));
-
-		return 0;
+		return pManagedHost->Run(input);
 	}
 
 
@@ -114,11 +106,14 @@ extern "C"
 		try
 		{
 			// bind the to CLR
-			HRESULT hrBind = CClrHost::BindToRuntime(&pClr.GetInterfacePtr());
-			if (FAILED(hrBind))
-				_com_raise_error(hrBind);
-			// start it up
-			pClr->Start();
+			if (pClr.GetInterfacePtr() == NULL)
+			{
+				HRESULT hrBind = CClrHost::BindToRuntime(&pClr.GetInterfacePtr());
+				if (FAILED(hrBind))
+					_com_raise_error(hrBind);
+				// start it up
+				pClr->Start();
+			}
 		}
 		catch (const _com_error &e)
 		{
@@ -140,10 +135,28 @@ extern "C"
 		int returnCode = 0;
 		try
 		{
-			// bind the to CLR
-			
+			longlong val = 0;
+			uint i;
+			for (i = 0; i < args->arg_count; i++)
+			{
+				if (args->args[i] == NULL)
+					continue;
+				switch (args->arg_type[i]) {
+				case STRING_RESULT:			/* Add string lengths */
+					val += args->lengths[i];
+					break;
+				case INT_RESULT:			/* Add numbers */
+					val += RunApplication(pClr, *((longlong*)args->args[i]));
+					break;
+				case REAL_RESULT:			/* Add numers as longlong */
+					val += (longlong)((double)RunApplication(pClr, *((longlong*)args->args[i])));
+					break;
+				default:
+					break;
+				}
+			}
+			return val;
 			// run the application
-			returnCode = RunApplication(pClr, args->args[0]);
 		}
 		catch (const _com_error &e)
 		{
@@ -159,23 +172,5 @@ extern "C"
 
 	void myfunc_int_deinit(UDF_INIT *initid)
 	{
-		int returnCode = 0;
-		try
-		{
-
-			// finally, dispose of the managed hosts and shut down the runtime
-			pClr->Stop();
-		}
-		catch (const _com_error &e)
-		{
-			const wchar_t *message = (wchar_t *)e.Description() == NULL ?
-				L"" :
-				(wchar_t *)e.Description();
-			std::wcerr << L"Error 0x" << std::hex << e.Error() << L") : " << message << std::endl;
-
-			returnCode = e.Error();
-		}
-
-		CoUninitialize();
 	}
 }