////////////////////
    //test.sqx

    #define  LEN  12 
    EXEC SQL BEGIN DECLARE SECTION;
	    char name[LEN];
    EXEC SQL END DECLARE SECTION;
    

    rem =============================================
    rem Файл для компиляции исходников с embedded sql
    rem prep.bat
    rem =============================================
	@if exist % 1 .sqx @del % 1 .sqx > nul
	@if exist % 1 .obj @del % 1 .obj > nul
	@if exist % 1 .log @del % 1 .log > nul
	@if exist % 1 .cxx @del % 1 .cxx > nul
	@copy % 1 .cpp % 1 .sqx > nul
	@echo connect to SAMPLE user 'DB2ADMIN' using 'PASSSWWWDD' > % 1 .db2
	@echo prep % 1 .sqx bindfile using % 1 .bnd isolation ur >> % 1 .db2
	@echo bind % 1 .bnd blocking all queryopt  0  isolation ur grant public >> % 1 .db2
	@d:\sqllib\bin\db2clpex db2 -z % 1 .log -vf % 1 .db2
	@if not exist % 1 .bnd ( type % 1 .log; exit  1  )
	@type % 1 .log
	sqx2cpp % 1  > nul
	cl /nologo /MDd /W3 /Gm /GR /GX /ZI /Od /D "WIN32" /D "_DEBUG" /D "_WINDOWS" /D "_AFXDLL" /Fo"Debug/" /Fd"Debug/" /FD /GZ  /c % 1 .cxx
    

    /////////////////////////////////////
    // sqx2cpp.cpp
    // to compile:   cl sqx2cpp.cpp
    /////////////////////////////////////

	#include <stdlib.h>
	#include <stdio.h>
	#include <windows.h>
	#include <string.h>
	#include <iostream>

	using namespace std;

	class UIException {
	public:
		UIException(char *msg) {
			cout << msg << endl;
    	}
	};

	class UIMemFile {
    	long   len;
	    HANDLE mh;
    	char*  pData;
	public:
		UIMemFile(char* fname) {
    		cout << "File:" << fname << endl;
			HANDLE hf;
  			hf=CreateFile(
        		fname,
            	GENERIC_READ|GENERIC_WRITE,
	            FILE_SHARE_READ|FILE_SHARE_WRITE,
    	        NULL,
        	    OPEN_EXISTING,
	            FILE_FLAG_SEQUENTIAL_SCAN,
    	        NULL
        	);
	        if (INVALID_HANDLE_VALUE==hf)
    	       	throw UIException("INVALID_HANDLE_VALUE");
        	
	        len=GetFileSize(hf,NULL);

    	    cout << "File size:" << len <<endl;

			mh=CreateFileMapping(hf,NULL,PAGE_READWRITE, 0 , 0 ,NULL);

	        if (NULL==mh)
    	    	throw UIException("CreateFileMapping");

	        CloseHandle(hf);
    	    pData=(char*)MapViewOfFile(mh,FILE_MAP_ALL_ACCESS, 0 , 0 , 0 );
        	if (NULL==pData)
        		throw UIException("MapViewOfFile");
	    }

    	~UIMemFile() {
    		CloseHandle(mh);
	        cout << "Closed." << endl;
    	}
	    long getlen() { return len; }
	    char& operator[] (long offset) {
    		if (offset>=len) throw UIException("Out of range");
        	return pData[offset];
	    }
    	char* operator () (long offset) {
    		if (offset>=len) throw UIException("Out of range");
	        return &pData[offset];
    	}
	};

	bool strcmpz(char* a,char *p) {
    	for (long i= 0 ;p!= 0 ;i++) {
        	if (p[i]!=a[i]) return false;
	    }
    	return true;
	} 

	char *patch;
	char *fname;
	char *pattern;

	void main(int argc,char *argv[]) {
    	if(argc!= 2 ) {
    		cout << "Usage: sqx2cpp {filename}" << endl;
	        exit( 0 );
    	}

	    patch=new char[strlen(argv[ 1 ])+ 5 ];
    	fname=new char[strlen(argv[ 1 ])+ 5 ];
	    pattern=new char[strlen(argv[ 1 ])+ 5 ];

    	sprintf(patch,"%s.cpp",argv[ 1 ]);
	    sprintf(pattern,"%s.sqx",argv[ 1 ]);
    	sprintf(fname,"%s.cxx",argv[ 1 ]);

		UIMemFile eecxxdll(fname);
    	long i;
	    long patternlen=strlen(pattern);

    	for(i= 0 ; i+patternlen<eecxxdll.getlen(); i++) {
			if (strcmpz(eecxxdll(i),pattern)) {
        		cout << "Patched at offset:" << i << endl;
	            for(long j= 0 ;patch[j]!= 0 ;j++) {
    	            eecxxdll[i+j]=patch[j];
        	    }
	        }
	    }

	    delete patch;
    	delete pattern;
	    delete fname;
	}
    

     [i]---------------------------------------------------------------
 
     --ttt.sql
 
	 --Cкрип выполняется командой:
 
	 --d:\SQLLIB\BIN\db2clpex.exe db2 -z ttt.log -v -td@ -f ttt.sql
 
     ---------------------------------------------------------------
 
	CONNECT TO SAMPLE USER db2admin USING 'ibmdb2'@
    CREATE TABLE TEST (
    	ID INTEGER NOT NULL,
        NAME CHAR( 35 ),
        CONSTRAINT AtID_PK PRIMARY KEY (ID)
    )@
	CREATE SEQUENCE S_TEST
		AS INTEGER
		START WITH  0 
    	INCREMENT BY  1 
	    NOMINVALUE
    	NOMAXVALUE
	    NO CYCLE
		CACHE  1000 
	@
	

	void CXX5View::OnStart() 
	{
		// TODO: Add your control notification handler code here
		pTT=new CTT(this);
		pTT->CreateThread();
		GetDlgItem(IDC_START)->EnableWindow(FALSE);
		GetDlgItem(IDC_SUSPEND)->EnableWindow(TRUE);
		GetDlgItem(IDC_RESUME)->EnableWindow(FALSE);
		GetDlgItem(IDC_TERMINATE)->EnableWindow(TRUE);
	}
    ...
	void CXX5View::OnSuspend()
	{
		// TODO: Add your control notification handler code here
		if (pTT!=NULL) {
			(pTT->pSection)->Lock();
			pTT->SuspendThread();
			GetDlgItem(IDC_SUSPEND)->EnableWindow(FALSE);
			GetDlgItem(IDC_RESUME)->EnableWindow(TRUE);
			GetDlgItem(IDC_TERMINATE)->EnableWindow(TRUE);
			(pTT->pSection)->Unlock();
		}
	}
    ...
	void CXX5View::OnResume()
	{
		// TODO: Add your control notification handler code here
		pTT->ResumeThread();
		GetDlgItem(IDC_SUSPEND)->EnableWindow(TRUE);
		GetDlgItem(IDC_RESUME)->EnableWindow(FALSE);
		GetDlgItem(IDC_TERMINATE)->EnableWindow(TRUE);
	}

	BOOL CXX5View::DestroyWindow() 
	{
		MessageBox("Terminate thread on Destroy");
		// TODO: Add your specialized code here and/or call the base class
		if (pTT!=NULL) {
			while (!(pTT->pSection)->Lock()) {}
			pTT->SuspendThread();
			TerminateThread(pTT->m_hThread, 0 );
			(pTT->pSection)->Unlock();
			delete pTT;
			pTT=NULL;
		}
		return CFormView::DestroyWindow();
	}
    ...
	void CXX5View::OnTerminate()
	{
		// TODO: Add your control notification handler code here
		if (pTT==NULL) return;
		while (!(pTT->pSection)->Lock()){};
		::TerminateThread(pTT->m_hThread, 0 );	
		GetDlgItem(IDC_START)->EnableWindow(TRUE);
		GetDlgItem(IDC_SUSPEND)->EnableWindow(FALSE);
		GetDlgItem(IDC_RESUME)->EnableWindow(FALSE);
		GetDlgItem(IDC_TERMINATE)->EnableWindow(FALSE);
		(pTT->pSection)->Unlock();
		delete pTT;
		pTT=NULL;
	}
    ...


    

	#if !defined(AFX_TT_H__BC791288_2AD1_48C5_AFE3_39CDB95AB411__INCLUDED_)
	#define AFX_TT_H__BC791288_2AD1_48C5_AFE3_39CDB95AB411__INCLUDED_

	#if _MSC_VER >  1000 
	#pragma once
	#endif // _MSC_VER >  1000 
	// TT.h : header file
	//



	/////////////////////////////////////////////////////////////////////////////
	// CTT thread

	class CTT : public CWinThread
	{
		DECLARE_DYNCREATE(CTT)
	protected:
		CTT();           // protected constructor used by dynamic creation
	// Attributes
	public:
		CTT(CFormView *pV){
			pView=pV;
			pSection=new CCriticalSection;
		}
		CFormView *pView;
		CCriticalSection *pSection;
		void **ppCtx;
		struct sqlca sqlca;
	// Operations
		public:

	// Overrides
	// ClassWizard generated virtual function overrides
	//{{AFX_VIRTUAL(CTT)
	public:
		virtual BOOL InitInstance();
		virtual int ExitInstance();
		virtual int Run();
	//}}AFX_VIRTUAL

	// Implementation
	protected:
	public:
		virtual ~CTT();

		// Generated message map functions
		//{{AFX_CTT
			// NOTE - the ClassWizard will add and remove member functions here.
		//}}AFX_MSG

	DECLARE_MESSAGE_MAP()
	};

	/////////////////////////////////////////////////////////////////////////////

	//{{AFX_INSERT_LOCATION}}
	// Microsoft Visual C++ will insert additional declarations immediately before the previous line.

	#endif // !defined(AFX_TT_H__BC791288_2AD1_48C5_AFE3_39CDB95AB411__INCLUDED_)
    

	// TT.cpp : implementation file
	//

	#include "stdafx.h"
	#include "TT.h"
	#include "XX5.h"

	#include "XX5Doc.h"
	#include "XX5View.h"

	#ifdef _DEBUG
	#define new DEBUG_NEW
	#undef THIS_FILE
	static char THIS_FILE[] = __FILE__;
	#endif

	/////////////////////////////////////////////////////////////////////////////
	// CTT

	IMPLEMENT_DYNCREATE(CTT, CWinThread)

	CTT::CTT()
	{
		ppCtx=(void**)new char[ 2048 ];
	}

	CTT::~CTT()
	{
		delete pSection;
	}

	BOOL CTT::InitInstance()
	{
		// TODO:  perform and per-thread initialization here
		return TRUE;
	}

	int CTT::ExitInstance()
	{
		// TODO:  perform any per-thread cleanup here
		return CWinThread::ExitInstance();
	}

	BEGIN_MESSAGE_MAP(CTT, CWinThread)
		//{{AFX_MSG_MAP(CTT)
			// NOTE - the ClassWizard will add and remove mapping macros here.
		//}}AFX_MSG_MAP
	END_MESSAGE_MAP()

	/////////////////////////////////////////////////////////////////////////////
	// CTT message handlers

	int CTT::Run() 
	{
		// TODO: Add your specialized code here and/or call the base class
        // -----------------------------------------------------------
 
        //Установим минимальный приоритет потока, в противном случае
        //от сожрет все ресурсы системы так, что мы даже на экране
        //ничего не увидим
        // -----------------------------------------------------------
 
		this->SetThreadPriority(THREAD_PRIORITY_IDLE);
		// -----------------------------------------------------------
 
        //Здесь будет выделена память под контекст
        //потока команд DB2. Почему-то что и сколько выделять 
        //не описано в документации. Я выделил наобум. Прокатило
        //Запускал одновременно до  50  потоков. Все работает.
        // -----------------------------------------------------------
 
		ppCtx=(void **) new char[ 1024 ]; //Буфер под контекст
		char buf[ 15 ];					//Бувер для форматирования
		long i= 0 ;						//Кол-во добавленных записей

		// --------------------------------------------------------------
 
        //Получаем контекст, сразу же присоединив его к текущему потоку
        // --------------------------------------------------------------
 
		i=sqleBeginCtx(ppCtx,SQL_CTX_BEGIN_ALL,NULL,&sqlca);
		sprintf(buf,"%d",i);
		(((CXX5View*)pView)->GetDlgItem(IDC_CNT))->SetWindowText(buf);

		// ----------------------------
 
    	//Собственно выполнение потока
        // ----------------------------	
 
		while (true) {
			i++;
			sprintf(buf,"%d",i);
            // -------------------------------------------------
 
            //Вывод информации о количестве добавленных записей
            // -------------------------------------------------
 
			(((CXX5View*)pView)->GetDlgItem(IDC_CNT))->SetWindowText(buf);

            // --------------------------------
 
            //Добавление записи в таблицу test
            // --------------------------------
 
			EXEC SQL INSERT INTO TEST (id,Name)
            	VALUES (NEXTVAL FOR S_TEST,CURRENT TIMESTAMP);

            // ---------------------------------------
 
            //В случае ошибки прерываем работу цикла
            // ---------------------------------------
 
			if (SQLCODE) {
				EXEC SQL ROLLBACK WORK;
				break;
			} else {
				EXEC SQL COMMIT WORK;
			}
            // ------------------------------------------
 
            //Каждая нить будет генерировать  1000  значений
            //Если у вас есть желание, то можете задавать кол-во
            //в поле IDC_CNT
            // ------------------------------------------
 
			if (i> 1000 ) break;
		}
        // ---------------------------------------------
 
		//После того, как нить отработала отсоединяем 
        //контекст от базы данных и убиваем его
        // ---------------------------------------------
 
		EXEC SQL CONNECT RESET;
		i=sqleEndCtx(ppCtx,SQL_CTX_END_ALL,NULL,&sqlca);
		sprintf(buf,"%d",i);
		(((CXX5View*)pView)->GetDlgItem(IDC_CNT))->SetWindowText(buf);
		while(!pSection->Lock()){};
		(((CXX5View*)pView)->pTT)=NULL;
		pSection->Unlock();
		::ExitThread( 0 );
		return CWinThread::Run();
	}