|
|
@@ -218,18 +218,21 @@ BOOL COtlConnHost::ExecCommand( LPCTSTR lpszSQL )
|
|
218
|
218
|
{
|
|
219
|
219
|
DB_TYPE type = GetDBType();
|
|
220
|
220
|
CString strSQL = lpszSQL;
|
|
221
|
|
-
|
|
222
|
|
- if( DB_MySQL == type )
|
|
223
|
|
- strSQL = GetStringForMySQL( lpszSQL );
|
|
224
|
|
-
|
|
|
221
|
+ CSingleLock lock(&m_LockSection);
|
|
|
222
|
+ if (DB_MySQL == type) {
|
|
|
223
|
+ strSQL = GetStringForMySQL(lpszSQL);
|
|
|
224
|
+ }
|
|
225
|
225
|
try
|
|
226
|
226
|
{
|
|
227
|
|
- CSingleLock lock( &m_LockSection, TRUE );
|
|
228
|
|
- otl_cursor::direct_exec( m_OtlConn, strSQL, otl_exception::enabled );
|
|
|
227
|
+ //CSingleLock lock( &m_LockSection, TRUE );
|
|
|
228
|
+ lock.Lock();
|
|
|
229
|
+ long nResult = otl_cursor::direct_exec(m_OtlConn, strSQL, otl_exception::enabled);
|
|
|
230
|
+ lock.Unlock();
|
|
229
|
231
|
}
|
|
230
|
232
|
catch( otl_exception& e )
|
|
231
|
233
|
{
|
|
232
|
234
|
this->ProcException( e );
|
|
|
235
|
+ lock.Unlock();
|
|
233
|
236
|
return FALSE;
|
|
234
|
237
|
}
|
|
235
|
238
|
|