#include <windows.h>
#include <SQL.h>
#include <SQLEXT.h>
#include <iostream.h>
#include <assert.h>

#define CHECK_ODBC_RES(exp)  rc = exp; if(rc != SQL_SUCCESS && rc != SQL_SUCCESS_WITH_INFO) throw rc 
#define CHECK_ODBC_RES_OK(exp)  rc = exp; if(rc != SQL_SUCCESS)  throw rc 


void main()
{

//MySQL
  SQLWCHAR * pServer = (SQLWCHAR*)L"MySQLlocal";
	SQLWCHAR * pUser = (SQLWCHAR*)L"rnddb6";
	SQLWCHAR * pPassword = (SQLWCHAR*)L"rnddb6";

	SQLWCHAR * pCatalog = (SQLWCHAR*)L"rnddb6";
	SQLWCHAR * pSchema = (SQLWCHAR*)L"";
	SQLWCHAR * pTable = (SQLWCHAR*)L"t_length";

	SQLRETURN rc;
	SQLHANDLE hEnv = NULL;
	SQLHANDLE hDBC = NULL;	
	SQLHANDLE hSTMS = NULL;
	SQLSMALLINT nCols;
	SQLINTEGER  nLen;
	int i;
	int iAttr;
	try
	{
		CHECK_ODBC_RES_OK(::SQLAllocHandle(SQL_HANDLE_ENV,SQL_NULL_HANDLE,&hEnv));

		CHECK_ODBC_RES_OK(::SQLSetEnvAttr(hEnv, SQL_ATTR_ODBC_VERSION,(SQLPOINTER)SQL_OV_ODBC2,0));

		CHECK_ODBC_RES_OK(::SQLAllocHandle(SQL_HANDLE_DBC,hEnv,&hDBC));

		CHECK_ODBC_RES(::SQLConnectW(hDBC,pServer,SQL_NTS,pUser,SQL_NTS,pPassword,SQL_NTS));

		CHECK_ODBC_RES_OK(::SQLAllocHandle(SQL_HANDLE_STMT,hDBC,&hSTMS));


		CHECK_ODBC_RES_OK(SQLColumnsW(hSTMS,
				pCatalog, ((pCatalog) ? SQL_NTS :0),
				pSchema, ((pSchema) ? SQL_NTS :0),
				pTable, ((pTable) ? SQL_NTS :0),
				NULL, 
				0));



		CHECK_ODBC_RES_OK(::SQLNumResultCols(hSTMS, &nCols));//SQL_SUCCESS_WITH_INFO
	
		SQLSMALLINT pType[100];
		char pBuf[50][1000];
		short pShort[50];
		int   pInt[50];
		SQLINTEGER cbLen[100];
		cout <<"Col Name:"<<endl;
		for(i=0; i < nCols; i++ )
		{
			SQLSMALLINT sLength;
			SQLSMALLINT sType;
			char pColName[255];
			unsigned long	lLength;   
			short	sScale;
			short uFlag;

			CHECK_ODBC_RES(::SQLDescribeCol(hSTMS,i+1,(SQLCHAR*)pColName,	255,&sLength,	&sType,	&lLength,
								&sScale,&uFlag ));
			if(sType == SQL_C_CHAR || sType == SQL_VARCHAR || sType == -9)
			{
				cbLen[i] = -1;
				CHECK_ODBC_RES_OK(SQLBindCol(hSTMS, i+1, SQL_C_CHAR, pBuf[i], lLength+1,
            &cbLen[i]));
			}
			else if(sType ==SQL_SMALLINT)
			{
				CHECK_ODBC_RES_OK(SQLBindCol(hSTMS, i+1, SQL_C_SHORT, &pShort[i], sizeof(short),
							&cbLen[i]));
			}
			else if(sType ==SQL_INTEGER)
			{
				CHECK_ODBC_RES_OK(SQLBindCol(hSTMS, i+1, SQL_C_SLONG, &pInt[i], sizeof(int),
							&cbLen[i]));
			}
			else
				;//assert(0);
			
			pType[i] = sType;//SQL_C_CHAR
			cout <<pColName<<"#";
		}	             
		cout <<"\r\n"<<endl;

		while ((rc = SQLFetch(hSTMS)) == SQL_SUCCESS )
		{

			for(i=0; i<nCols; i++)
			{
				if(pType[i] == SQL_C_CHAR || pType[i] == SQL_VARCHAR || pType[i] == -9)
				{
					if(cbLen[i] >=0)
						cout<< pBuf[i]<<'#';
					else
						cout<<'#';
				}
				else if(pType[i] ==SQL_SMALLINT)
				{
					cout<<pShort[i]<<'#'; 
				}
				else if(pType[i] ==SQL_INTEGER)
				{
					cout << pInt[i]<<'#';
				}
			}
			cout <<"\r\n"<<endl;
		}
	}
	catch(SQLRETURN er)
	{
		SQLSMALLINT		cberrormsg		= 0;
		SQLINTEGER		SqlDbCode 		= 0;
		SQLCHAR			strDbMessage[100];
		SQLCHAR			strState[100];

		rc = SQLError (	hEnv,	hDBC,	hSTMS,	strState,	&SqlDbCode,	strDbMessage,	100 ,
						&cberrormsg);

		cout<<er<<"err:"<<strDbMessage<<endl;
	}
	catch(...)
	{
		cout<<"err";
	}
	SQLFreeHandle(SQL_HANDLE_STMT,hSTMS);
	SQLFreeHandle(SQL_HANDLE_DBC,hDBC);
	SQLFreeHandle(SQL_HANDLE_ENV,hEnv);
}