开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
S3PDBConnectionPool.cpp
资源名称：SwordOnline.rar　[点击查看]
上传用户：dzyhzl
上传日期：2019-04-29
资源大小：56270k
文件大小：11k
源码类别：

模拟服务器

开发平台：

C/C++

S3PDBConnectionPool.cpp：源码内容
  1. //-----------------------------------------//
  2. //                                         //
  3. //  File : S3PDBConnectionPool.cpp  //
  4. // Author : Yang Xiaodong            //
  5. // Modified : 8/24/2002                //
  6. //                                         //
  7. //-----------------------------------------//
  8. #include "S3PDBConnectionPool.h"
  10. S3PDBConnectionPool* S3PDBConnectionPool::m_pInstance = NULL;
  11. std::string S3PDBConnectionPool::m_strINIPath = "";
  12. S3PDBConnectionPool::_DATABASEINFO S3PDBConnectionPool::m_AccountDBInfo;
  13. S3PDBConnectionPool::_DATABASEINFO S3PDBConnectionPool::m_RoleDBInfo;
  14. S3PDBConnectionPool::_DATABASEINFO S3PDBConnectionPool::m_CardDBInfo;
  16. S3PDBConnectionPool::S3PDBConnectionPool()
  17. {
  19. }
  21. S3PDBConnectionPool::~S3PDBConnectionPool()
  22. {
  24. }
  26. void S3PDBConnectionPool::InitAccountDBInfo()
  27. {
  28. TCHAR szServer[def_KEYNAMELEN];
  29. TCHAR szDataBase[def_KEYNAMELEN];
  30. TCHAR szUser[def_KEYNAMELEN];
  31. TCHAR szPassword[def_KEYNAMELEN];
  33. DWORD dwLen =
  34. KPIGetPrivateProfileString( def_ACCOUNTSECTIONNAME,
  35. def_SERVERKEYNAME,
  36. "",
  37. szServer,
  38. def_KEYNAMELEN,
  39. m_strINIPath.c_str() );
  40. if ( dwLen < def_KEYNAMELEN )
  41. {
  42. szServer[dwLen] = 0;
  43. }
  44. else
  45. {
  46. szServer[0] = 0;
  47. }
  48. dwLen =
  49. KPIGetPrivateProfileString( def_ACCOUNTSECTIONNAME,
  50. def_DATABASEKEYNAME,
  51. "",
  52. szDataBase,
  53. def_KEYNAMELEN,
  54. m_strINIPath.c_str() );
  55. if ( dwLen < def_KEYNAMELEN )
  56. {
  57. szDataBase[dwLen] = 0;
  58. }
  59. else
  60. {
  61. szDataBase[0] = 0;
  62. }
  63. dwLen =
  64. KPIGetPrivateProfileString( def_ACCOUNTSECTIONNAME,
  65. def_USERKEYNAME,
  66. "",
  67. szUser,
  68. def_KEYNAMELEN,
  69. m_strINIPath.c_str() );
  70. if ( dwLen < def_KEYNAMELEN )
  71. {
  72. szUser[dwLen] = 0;
  73. }
  74. else
  75. {
  76. szUser[0] = 0;
  77. }
  78. dwLen =
  79. KPIGetPrivateProfileString( def_ACCOUNTSECTIONNAME,
  80. def_PASSWORDKEYNAME,
  81. "",
  82. szPassword,
  83. def_KEYNAMELEN,
  84. m_strINIPath.c_str() );
  85. if ( dwLen < def_KEYNAMELEN )
  86. {
  87. szPassword[dwLen] = 0;
  88. }
  89. else
  90. {
  91. szPassword[0] = 0;
  92. }
  93. m_AccountDBInfo.strServer = szServer;
  94. m_AccountDBInfo.strDataBase = szDataBase;
  95. m_AccountDBInfo.strUser = szUser;
  96. m_AccountDBInfo.strPassword = szPassword;
  97. }
  99. void S3PDBConnectionPool::InitRoleDBInfo()
  100. {
  101. TCHAR szServer[def_KEYNAMELEN];
  102. TCHAR szDataBase[def_KEYNAMELEN];
  103. TCHAR szUser[def_KEYNAMELEN];
  104. TCHAR szPassword[def_KEYNAMELEN];
  106. DWORD dwLen =
  107. KPIGetPrivateProfileString( def_ROLESECTIONNAME,
  108. def_SERVERKEYNAME,
  109. "",
  110. szServer,
  111. def_KEYNAMELEN,
  112. m_strINIPath.c_str() );
  113. if ( dwLen < def_KEYNAMELEN )
  114. {
  115. szServer[dwLen] = 0;
  116. }
  117. else
  118. {
  119. szServer[0] = 0;
  120. }
  121. dwLen =
  122. KPIGetPrivateProfileString( def_ROLESECTIONNAME,
  123. def_DATABASEKEYNAME,
  124. "",
  125. szDataBase,
  126. def_KEYNAMELEN,
  127. m_strINIPath.c_str() );
  128. if ( dwLen < def_KEYNAMELEN )
  129. {
  130. szDataBase[dwLen] = 0;
  131. }
  132. else
  133. {
  134. szDataBase[0] = 0;
  135. }
  136. dwLen =
  137. KPIGetPrivateProfileString( def_ROLESECTIONNAME,
  138. def_USERKEYNAME,
  139. "",
  140. szUser,
  141. def_KEYNAMELEN,
  142. m_strINIPath.c_str() );
  143. if ( dwLen < def_KEYNAMELEN )
  144. {
  145. szUser[dwLen] = 0;
  146. }
  147. else
  148. {
  149. szUser[0] = 0;
  150. }
  151. dwLen =
  152. KPIGetPrivateProfileString( def_ROLESECTIONNAME,
  153. def_PASSWORDKEYNAME,
  154. "",
  155. szPassword,
  156. def_KEYNAMELEN,
  157. m_strINIPath.c_str() );
  158. if ( dwLen < def_KEYNAMELEN )
  159. {
  160. szPassword[dwLen] = 0;
  161. }
  162. else
  163. {
  164. szPassword[0] = 0;
  165. }
  167. m_RoleDBInfo.strServer = szServer;
  168. m_RoleDBInfo.strDataBase = szDataBase;
  169. m_RoleDBInfo.strUser = szUser;
  170. m_RoleDBInfo.strPassword = szPassword;
  171. }
  173. void S3PDBConnectionPool::InitCardDBInfo()
  174. {
  175. TCHAR szServer[def_KEYNAMELEN];
  176. TCHAR szDataBase[def_KEYNAMELEN];
  177. TCHAR szUser[def_KEYNAMELEN];
  178. TCHAR szPassword[def_KEYNAMELEN];
  180. DWORD dwLen =
  181. KPIGetPrivateProfileString( def_CARDSECTIONNAME,
  182. def_SERVERKEYNAME,
  183. "",
  184. szServer,
  185. def_KEYNAMELEN,
  186. m_strINIPath.c_str() );
  187. if ( dwLen < def_KEYNAMELEN )
  188. {
  189. szServer[dwLen] = 0;
  190. }
  191. else
  192. {
  193. szServer[0] = 0;
  194. }
  195. dwLen =
  196. KPIGetPrivateProfileString( def_CARDSECTIONNAME,
  197. def_DATABASEKEYNAME,
  198. "",
  199. szDataBase,
  200. def_KEYNAMELEN,
  201. m_strINIPath.c_str() );
  202. if ( dwLen < def_KEYNAMELEN )
  203. {
  204. szDataBase[dwLen] = 0;
  205. }
  206. else
  207. {
  208. szDataBase[0] = 0;
  209. }
  210. dwLen =
  211. KPIGetPrivateProfileString( def_CARDSECTIONNAME,
  212. def_USERKEYNAME,
  213. "",
  214. szUser,
  215. def_KEYNAMELEN,
  216. m_strINIPath.c_str() );
  217. if ( dwLen < def_KEYNAMELEN )
  218. {
  219. szUser[dwLen] = 0;
  220. }
  221. else
  222. {
  223. szUser[0] = 0;
  224. }
  225. dwLen =
  226. KPIGetPrivateProfileString( def_CARDSECTIONNAME,
  227. def_PASSWORDKEYNAME,
  228. "",
  229. szPassword,
  230. def_KEYNAMELEN,
  231. m_strINIPath.c_str() );
  232. if ( dwLen < def_KEYNAMELEN )
  233. {
  234. szPassword[dwLen] = 0;
  235. }
  236. else
  237. {
  238. szPassword[0] = 0;
  239. }
  241. m_CardDBInfo.strServer = szServer;
  242. m_CardDBInfo.strDataBase = szDataBase;
  243. m_CardDBInfo.strUser = szUser;
  244. m_CardDBInfo.strPassword = szPassword;
  245. }
  247. void S3PDBConnectionPool::Init( const std::string &strINIPath )
  248. {
  249. m_strINIPath = strINIPath;
  251. if ( !( m_strINIPath.empty() ) )
  252. {
  253. InitAccountDBInfo();
  254. InitRoleDBInfo();
  255. InitCardDBInfo();
  256. }
  257. }
  259. S3PDBConnectionPool* S3PDBConnectionPool::Instance()
  260. {
  261. if ( NULL == m_pInstance )
  262. {
  263. m_pInstance = new S3PDBConnectionPool;
  264. //Question no delete,must delete in somewhere romandoufind
  265. }
  266. return m_pInstance;
  267. }
  269. void S3PDBConnectionPool::ReleaseInstance()
  270. {
  271. if ( NULL != m_pInstance )
  272. {
  273. m_pInstance->Release();
  274. m_pInstance = NULL;
  275. }
  276. }
  278. _CONNECTION_ID S3PDBConnectionPool::ApplyAccountDBCon()
  279. {
  280. _CONNECTION_ID ret;
  281. ret.dwID = def_ERRORCONID;
  282. ret.pCon = NULL;
  284. DWORD dwNullID = def_ERRORCONID;
  286. DWORD dwSize = m_AccountMap.size();
  287. for ( DWORD i = 0; i < dwSize; i++ )
  288. {
  289. if ( NULL != m_AccountMap[i].pCon )
  290. {
  291. if ( TRUE != m_AccountMap[i].bBusy )
  292. {
  293. ret.dwID = i;
  294. ret.pCon = m_AccountMap[i].pCon;
  295. break;
  296. }
  297. }
  298. else if ( def_ERRORCONID == dwNullID )
  299. {
  300. dwNullID = i;
  301. }
  302. }
  304. if ( NULL == ret.pCon )
  305. {
  306. Connection* pCon =
  307. ( Connection* )( malloc( sizeof( Connection ) ) );
  308. if ( NULL != pCon )
  309. {
  310. if ( TRUE == pCon->connect( m_AccountDBInfo.strDataBase.c_str(),
  311. m_AccountDBInfo.strServer.c_str(),
  312. m_AccountDBInfo.strUser.c_str(),
  313. m_AccountDBInfo.strPassword.c_str() ) )
  314. {
  315. if ( def_ERRORCONID != dwNullID )
  316. {
  317. ret.dwID = dwNullID;
  318. }
  319. else
  320. {
  321. ret.dwID = dwSize;
  322. }
  323. ret.pCon = pCon;
  324. _CONNECTIONITEM conItem = { TRUE, pCon };
  325. m_AccountMap[ret.dwID] = conItem;
  326. }
  327. else
  328. {
  329. free( pCon );
  330. pCon = NULL;
  331. }
  332. }
  333. }
  335. return ret;
  336. }
  338. _CONNECTION_ID S3PDBConnectionPool::ApplyRoleDBCon()
  339. {
  340. _CONNECTION_ID ret;
  341. ret.dwID = def_ERRORCONID;
  342. ret.pCon = NULL;
  344. DWORD dwNullID = def_ERRORCONID;
  346. DWORD dwSize = m_RoleMap.size();
  347. for ( DWORD i = 0; i < dwSize; i++ )
  348. {
  349. if ( NULL != m_RoleMap[i].pCon )
  350. {
  351. if ( TRUE != m_RoleMap[i].bBusy )
  352. {
  353. ret.dwID = i;
  354. ret.pCon = m_RoleMap[i].pCon;
  355. break;
  356. }
  357. }
  358. else if ( def_ERRORCONID == dwNullID )
  359. {
  360. dwNullID = i;
  361. }
  362. }
  363. if ( NULL == ret.pCon )
  364. {
  365. Connection* pCon =
  366. ( Connection* )( malloc( sizeof( Connection ) ) );
  367. //Question up no delete ,must delete
  368. if ( NULL != pCon )
  369. {
  370. if ( TRUE == pCon->connect( m_RoleDBInfo.strDataBase.c_str(),
  371. m_RoleDBInfo.strServer.c_str(),
  372. m_RoleDBInfo.strUser.c_str(),
  373. m_RoleDBInfo.strPassword.c_str() ) )
  374. {
  375. if ( def_ERRORCONID != dwNullID )
  376. {
  377. ret.dwID = dwNullID;
  378. }
  379. else
  380. {
  381. ret.dwID = dwSize;
  382. }
  383. ret.pCon = pCon;
  384. _CONNECTIONITEM conItem = { TRUE, pCon };
  385. m_RoleMap[ret.dwID] = conItem;
  386. }
  387. else
  388. {
  389. free( pCon );
  390. pCon = NULL;
  391. }
  392. }
  393. }
  395. return ret;
  396. }
  398. _CONNECTION_ID S3PDBConnectionPool::ApplyCardDBCon()
  399. {
  400. _CONNECTION_ID ret;
  401. ret.dwID = def_ERRORCONID;
  402. ret.pCon = NULL;
  403. DWORD dwNullID = def_ERRORCONID;
  405. DWORD dwSize = m_CardMap.size();
  406. for ( DWORD i = 0; i < dwSize; i++ )
  407. {
  408. if ( NULL != m_CardMap[i].pCon )
  409. {
  410. if ( TRUE != m_CardMap[i].bBusy )
  411. {
  412. ret.dwID = i;
  413. ret.pCon = m_CardMap[i].pCon;
  414. break;
  415. }
  416. }
  417. else if ( def_ERRORCONID == dwNullID )
  418. {
  419. dwNullID = i;
  420. }
  421. }
  422. if ( NULL == ret.pCon )
  423. {
  424. Connection* pCon =
  425. ( Connection* )( malloc( sizeof( Connection ) ) );
  426. if ( NULL != pCon )
  427. {
  428. if ( TRUE == pCon->connect( m_CardDBInfo.strDataBase.c_str(),
  429. m_CardDBInfo.strServer.c_str(),
  430. m_CardDBInfo.strUser.c_str(),
  431. m_CardDBInfo.strPassword.c_str() ) )
  432. {
  433. if ( def_ERRORCONID != dwNullID )
  434. {
  435. ret.dwID = dwNullID;
  436. }
  437. else
  438. {
  439. ret.dwID = dwSize;
  440. }
  441. ret.pCon = pCon;
  442. _CONNECTIONITEM conItem = { TRUE, pCon };
  443. m_CardMap[ret.dwID] = conItem;
  444. }
  445. else
  446. {
  447. free( pCon );
  448. pCon = NULL;
  449. }
  450. }
  451. }
  453. return ret;
  454. }
  456. _CONNECTION_ID S3PDBConnectionPool::ApplyDBConnection( int iDBIdentifier )
  457. {
  458. _CONNECTION_ID ret;
  459. ret.dwID = def_ERRORCONID;
  460. ret.pCon = NULL;
  461. switch ( iDBIdentifier )
  462. {
  463. case def_ACCOUNTDB:
  464. ret = ApplyAccountDBCon();
  465. break;
  466. case def_ROLEDB:
  467. ret = ApplyRoleDBCon();
  468. break;
  469. case def_CARDDB:
  470. ret = ApplyCardDBCon();
  471. break;
  472. default:
  473. break;
  474. }
  475. return ret;
  476. }
  478. BOOL S3PDBConnectionPool::SetAccountDBConFree( DWORD dwConID )
  479. {
  480. BOOL bRet = FALSE;
  481. ConMap::iterator accountIterator = m_AccountMap.find( dwConID );
  482. if ( m_AccountMap.end() != accountIterator )
  483. {
  484. ( *accountIterator ).second.bBusy = FALSE;
  485. }
  486. return bRet;
  487. }
  489. BOOL S3PDBConnectionPool::SetRoleDBConFree( DWORD dwConID )
  490. {
  491. BOOL bRet = FALSE;
  492. ConMap::iterator roleIterator = m_RoleMap.find( dwConID );
  493. if ( m_RoleMap.end() != roleIterator )
  494. {
  495. ( *roleIterator ).second.bBusy = FALSE;
  496. }
  497. return bRet;
  498. }
  500. BOOL S3PDBConnectionPool::SetCardDBConFree( DWORD dwConID )
  501. {
  502. BOOL bRet = FALSE;
  503. ConMap::iterator cardIterator = m_CardMap.find( dwConID );
  504. if ( m_CardMap.end() != cardIterator )
  505. {
  506. ( *cardIterator ).second.bBusy = FALSE;
  507. }
  508. return bRet;
  509. }
  511. BOOL S3PDBConnectionPool::SetDBConFree( int iDBIdentifier, DWORD dwConID )
  512. {
  513. BOOL bRet = FALSE;
  514. switch ( iDBIdentifier )
  515. {
  516. case def_ACCOUNTDB:
  517. bRet = SetAccountDBConFree( dwConID );
  518. break;
  519. case def_ROLEDB:
  520. bRet = SetRoleDBConFree( dwConID );
  521. break;
  522. case def_CARDDB:
  523. bRet = SetCardDBConFree( dwConID );
  524. break;
  525. default:
  526. break;
  527. }
  528. return bRet;
  529. }
  531. void S3PDBConnectionPool::ReleaseAccountMap()
  532. {
  533. DWORD dwSize = m_AccountMap.size();
  534. for ( DWORD i = 0; i < dwSize; i++ )
  535. {
  536. if ( NULL != m_AccountMap[i].pCon )
  537. {
  538. m_AccountMap[i].pCon->close();
  539. free( m_AccountMap[i].pCon );
  540. m_AccountMap[i].pCon = NULL;
  541. }
  542. }
  543. m_AccountMap.clear();
  544. }
  546. void S3PDBConnectionPool::ReleaseRoleMap()
  547. {
  548. DWORD dwSize = m_RoleMap.size();
  549. for ( DWORD i = 0; i < dwSize; i++ )
  550. {
  551. if ( NULL != m_RoleMap[i].pCon )
  552. {
  553. m_RoleMap[i].pCon->close();
  554. free( m_RoleMap[i].pCon );
  555. m_RoleMap[i].pCon = NULL;
  556. }
  557. }
  558. m_RoleMap.clear();
  559. }
  561. void S3PDBConnectionPool::ReleaseCardMap()
  562. {
  563. DWORD dwSize = m_CardMap.size();
  564. for ( DWORD i = 0; i < dwSize; i++ )
  565. {
  566. if ( NULL != m_CardMap[i].pCon )
  567. {
  568. m_CardMap[i].pCon->close();
  569. free( m_CardMap[i].pCon );
  570. m_CardMap[i].pCon = NULL;
  571. }
  572. }
  573. m_CardMap.clear();
  574. }
  576. void S3PDBConnectionPool::Release()
  577. {
  578. ReleaseAccountMap();
  579. ReleaseRoleMap();
  580. ReleaseCardMap();
  581. }