●ＯＤＢＣ

1. □ODBCでデータベースにアクセスする見本（レコードセット）。

   CString strName;
   CString strCDE;
   CString strRow;

   m_pDb=new CDatabase(); ・・・１
   m_pDb->OpenEx("DSN=demo",0);・・・２

   
   CRecordset* pRc=new CRecordset(m_pDb);・・・３
   CString strSQL="SELECT NAME,SKU_CDE FROM SKUMST WHERE PSKU_CDE='" +strC+ "'";
   try{
   pRc->Open(CRecordset::snapshot,strSQL,CRecordset::readOnly);・・・４
   while (!pRc->IsEOF()){
   pRc->GetFieldValue("NAME",strName);・・・５
   pRc->GetFieldValue("SKU_CDE",strCDE);
   strRow = strName + "\t需要予測\t" + strCDE;
   m_fxgrid.AddItem(strRow,vtNone);
   pRc->MoveNext();・・・６
   }
   }
   catch(CDBException e){
   e.ReportError();
   delete(pRc);
   e.Delete();

   return 1;
   }
   pRc->Close();・・・７
   delete(pRc);

   m_pDb->Close();・・・８
   delete(m_pDb);

   　

   1. 手順１：Cdatabaseクラスインスタンスの作成
   2. 手順２：データベースのオープン（引数はＯＤＢＣデータソース）
   3. 手順３：CRcoudsetクラスインスタンスの作成
   4. 手順４：レコードセットのオープン（引数はＳＥＬＥＣＴ文）
   5. 手順５：データの取り出し
   6. 手順６：レコードセットポインターの更新
   7. 手順７：レコードセットのクローズ
   8. 手順８：データベースのクローズ



2. ODBCでデータベースにアクセスする見本（トランザクションの見本）。

pos = g_mapRecord.GetStartPosition();
m_pDb->BeginTrans();・・・１

while(pos != NULL ){
g_mapRecord.GetNextAssoc(pos,strKey,tabRecord);

if(SQL(tabRecord)){
m_pDb->Rollback・・・４
return -1;
}
}
m_pDb->CommitTrans();・・・３


long CFFCapDlg::SQL(FilterMNT& tag)
{


//SQL 作成 tag.EditDiv １：更新 、２：削除、３：追加

CString strSQL;
CString strUpd = "UPDATE FACTORYFILTERINGCAPABILITY SET ";
CString strDel = "DELETE FACTORYFILTERINGCAPABILITY WHERE ";
CString strIns = "INSERT INTO FACTORYFILTERINGCAPABILITY ";


switch( tag.EditDiv ){
case 1:
strSQL = strUpd+"BUSINESSOPERATION_CODE='"+tag.BusinessOperation_CODE
+"',SYSTEM_NO="+tag.System_NO
+",BEVERAGETYPE_CODE='"+tag.BeverageType_CODE
+"',MAXCAPABILITY="+tag.MaxCapability
+",FILTERINGCAPABILITY="+tag.FilteringCapability
+",PERCENTAGE="+tag.Percentage
+",APSTARTDATE=to_date("+tag.APSatrtDate+" 'yy-mm-dd'),APENDDATE=to_date("+tag.APEndDate+" 'yy-mm-dd') WHERE BUSINESSOPERATION_CODE='"
+tag.BusinessOperation_CODE+
"' AND SYSTEM_NO="+tag.System_NO+
" AND BEVERAGETYPE_CODE='"+tag.BeverageType_CODE+"'";

break;
case 2:
strSQL = strDel+ "BUSINESSOPERATION_CODE='"+tag.BusinessOperation_CODE+
"' AND SYSTEM_NO="+tag.System_NO+
" AND BEVERAGETYPE_CODE='"+tag.BeverageType_CODE+"'";
break;
case 3:
strSQL = strIns +" VALUES('"+tag.BusinessOperation_CODE+"',"
+tag.System_NO+","
+"'"+tag.BeverageType_CODE+"',"
+tag.MaxCapability+","
+tag.FilteringCapability+","
+tag.Percentage
+",to_date("+tag.APSatrtDate+" 'yy-mm-dd'),+to_date("+tag.APEndDate+" 'yy-mm-dd')";
break;
default:
break;
}

try{
m_pDb->ExecuteSQL(strSQL);・・・２
}

catch(CDBException e){
e.ReportError();

e.Delete();
return -1;
}

return 0;
}


　

1. 手順１：トランザクションの開始
2. ＳＱＬの実行
3. コミット
4. 更新処理中に失敗したらロールバック