sql2005 pool

#include "StdAfx.h"
#include "ConnPool.h"
#include <algorithm>

#define MIN_COUNT 10
#define MAX_COUNT 100
HANDLE hMutex;

ConnPool::ConnPool(void)
{
 this->Init();
}

ConnPool::~ConnPool(void)
{
}

ConnPool* ConnPool::cpInst = NULL;
ConnPool* ConnPool::GetInstance()
{
 if(NULL==cpInst)
 {
  cpInst = new ConnPool();
 }
 else
 {
  return cpInst;
 }
}

void ConnPool::Init()
{
 CoInitialize(NULL);
 for(int i=0;i<MIN_COUNT;i++)
 {
  ConnObj *co = new ConnObj;

  co->OpenConn();
  if(NULL!=co)
  {
   //lock
   WaitForSingleObject(hMutex,INFINITE);
   poolList.push_back(co);
   ReleaseMutex(hMutex);
  }
 }
}

ConnObj* ConnPool::Increase()
{
 int size = poolList.size();

 if(size<MAX_COUNT)
 {
  ConnObj *co = new ConnObj;

  co->OpenConn();
  if(NULL!=co)
  {
   //lock
   WaitForSingleObject(hMutex,INFINITE);
   poolList.push_back(co);
   ReleaseMutex(hMutex);
   return co;
  }
  else
  {
   return NULL;
  }
 }
 else
 {
  return NULL;
 }
}

ConnObj* ConnPool::GetConn()
{
 bool bSuc;
 for(list<ConnObj*>::iterator it = this->poolList.begin();it!=this->poolList.end();it++)
 {
  if(!(*it)->isUsed)
  {
   WaitForSingleObject(hMutex,INFINITE);
   (*it)->isUsed = true;
   (*it)->usedCount =  (*it)->usedCount + 1;
   ReleaseMutex(hMutex);
   bSuc = true;
   return (*it);
   break;
  }
 }

 //全满
 if(!bSuc)
 {
  return Increase();
 }
}

void ConnPool::DropConn(ConnObj* co)
{
 co->isUsed = false;
 co->usedCount = co->usedCount - 1;
}

 

 

 

 

 

 

#pragma once
#include <stdio.h>
#include <string>
#include <list>
#include <iostream>
#import "c:\Program Files\Common Files\System\ADO\msado15.dll"  no_namespace rename("EOF", "adoEOF")
#include "ConnObj.h"
using namespace std;

class ConnPool
{
private:
 static ConnPool* cpInst;
public:
 list<ConnObj*> poolList;

public:
 static ConnPool* GetInstance();
 void Init();
 ConnObj* Increase();
 ConnObj* GetConn();
 void DropConn(ConnObj* co);
public:
 ConnPool(void);
 ~ConnPool(void);
};

 

 

#include "StdAfx.h"
#include "ConnObj.h"

ConnObj::ConnObj(void)
{
 isUsed = false;
 isTrans = false;
 usedCount = 0;
}

ConnObj::~ConnObj(void)
{
}

void ConnObj::OpenConn()
{
 _bstr_t strConnect= "Provider=SQLOLEDB;Server=localhost;Database=bty_db_main;uid=sa; pwd=123";

 conn.CreateInstance("ADODB.Connection");
 conn->Open(strConnect,"","",adModeUnknown);
}

void ConnObj::CloseConn()
{
 conn->Close();
 conn = NULL;
}

 

 

 

 

#pragma once
#include <stdio.h>
#include <string>
#include <list>
#include <iostream>
#import "c:\Program Files\Common Files\System\ADO\msado15.dll"  no_namespace rename("EOF", "adoEOF")
using namespace std;

class ConnObj
{
public:
 _ConnectionPtr conn;
 bool isUsed;
 bool isTrans;
 int usedCount;
public:
 void OpenConn();
 void CloseConn();
public:
 ConnObj(void);
 ~ConnObj(void);
};

 

 

 

 

 

// sqt.cpp : 定义控制台应用程序的入口点。
//

#include "stdafx.h"
#include <stdio.h>
#include <string>
#include <iostream>
#include "ConnPool.h"
#import "c:\Program Files\Common Files\System\ADO\msado15.dll"  no_namespace rename("EOF", "adoEOF")
using namespace std;

int _tmain(int argc, _TCHAR* argv[])
{
 _bstr_t strConnect= "Provider=SQLOLEDB;Server=localhost;Database=bty_db_main;uid=sa; pwd=123";

 /*CoInitialize(NULL);
 _ConnectionPtr m_pConnection("ADODB.Connection");
 m_pConnection.CreateInstance("ADODB.Connection");
 m_pConnection->Open(strConnect,"","",adModeUnknown);

 if(m_pConnection==NULL)
 printf("conn error");

 printf("conn ok\n");

 _ConnectionPtr m_pConnection2("ADODB.Connection");
 m_pConnection2.CreateInstance("ADODB.Connection");
 m_pConnection2->Open(strConnect,"","",adModeUnknown);*/
 
 ConnObj *co = ConnPool::GetInstance()->GetConn();
 _ConnectionPtr m_pConnection = co->conn;

 _RecordsetPtr m_pRecordset("ADODB.Recordset");
 _bstr_t bstrSQL("select * from bty_product");

 if(FAILED(m_pRecordset->Open(bstrSQL,strConnect,adOpenStatic,adLockOptimistic,adCmdText)))
 {
  printf("Open table failed!");
  m_pRecordset.Release();
 }

 while(!m_pRecordset->GetadoEOF())
 {
  _variant_t varName;
  
  varName = m_pRecordset->GetCollect("prod_name");
  string strName =(char *)_bstr_t(varName);

  //printf("%s\n",strName);
  cout<<strName<<endl;

  m_pRecordset->MoveNext();
 }
 m_pRecordset->Close();
 m_pRecordset->Release();

 

 while(1)
 {

 }
 //getchar();

 return 0;
}