MFC+ADO+ACCESS创建数据库

发布日期：3/16/2007 2:31:19 PM  BENKONG

   最近偶然要做一个小型的数据库管理系统，为了方便用户无需自己用access创建数据库，所以，我必须设法让程序能够创建数据库，数据库表以及判断数据库表的存在。下面的程序代码希望能够为遇到这方面困难的朋友提供帮助：(2008/11/5重新编辑)

1. //1.引入ado库
3. #import "c:/Program Files/Common Files/System/ADO/Msadox.dll"  rename_namespace("ADOCG") rename("EOF", "adoXEOF") rename("DataTypeEnum","adoXDataTypeEnum") 
6. #import "C:/Program Files/Common Files/System/ADO/msado15.dll" named_guids rename("EOF","adoEOF"), rename("BOF","adoBOF")
8. using namespace ADODB;  
9. using namespace ADOCG;
11. #define TESTHR(x) if FAILED(x) _com_issue_error(x);
14. //2.创建ACCESS数据库 
16. BOOL CDeRenDlg::CreateMdb(CString strDBName)
17. { 
18.     CString strMdbConn = "Provider='Microsoft.JET.OLEDB.4.0';Data source = " + strDBName;
20.  try
21.  {
22.   HRESULT hr = S_OK; 
23.   _CatalogPtr pCatalog = NULL;
24.   _bstr_t cnnstring(strMdbConn);
25.   
26.   TESTHR(hr = pCatalog.CreateInstance(__uuidof (Catalog)));
27.         pCatalog->Create(cnnstring);
28.  }
30.  catch(_com_error e)
31.  {
32.   _bstr_t bstrDescription(e.Description());
33.   CString strErro=CString(_T("创建ACCEESS数据库出错: ")) 
34.                + (LPCSTR)e.Description()
35.       + CString(_T("Create ACCESS DB error: "))
36.       + (LPCSTR)e.Description();
37.   AfxMessageBox(strErro);
38.   return FALSE;
39.  }
41.  return TRUE;
42. }
45. //3.创建数据库表-材料表
46. BOOL CDeRenDlg::CreateTable( CString strTabName)
47. {
48.  HRESULT hr = S_OK;
50.     _CatalogPtr pCatalog = NULL;
51.     _TablePtr pTableNew = NULL;
52.     _IndexPtr pIndexNew = NULL;
53.     _IndexPtr pIndex  = NULL;
54.     _ColumnPtr pColumn  = NULL;
56.  CString strConn,strDBName;
58.  strDBName=this->GetDBName(m_nDBYear);
59.  CFileFind ff;
60.  if(!ff.FindFile(strDBName))
61.  {
62.   AfxMessageBox("数据库不存在，请先在高级设置对话框中创建数据库！");
63.   return FALSE;
64.  }
66.  strConn="Provider='Microsoft.JET.OLEDB.4.0';Data source = " + strDBName;
68.  _bstr_t strcnn(strConn);
69.     try
70.     {
71.         TESTHR(hr = pCatalog.CreateInstance (__uuidof(Catalog)));
72.         TESTHR(hr = pTableNew.CreateInstance(__uuidof(Table)));
73.         TESTHR(hr = pIndexNew.CreateInstance(__uuidof(Index)));
74.         TESTHR(hr = pIndex.CreateInstance   (__uuidof(Index)));
75.         TESTHR(hr = pColumn.CreateInstance  (__uuidof(Column)));
76.   
77.         // 连接
78.         pCatalog->PutActiveConnection(strcnn);
80.         // 表名
81.         pTableNew->Name = _bstr_t(strTabName);
82.   pTableNew->ParentCatalog = pCatalog;
85.   //
86.   //m_pTableNew->Columns->Append("ContactId", ::adInteger,0);          
87.         //m_pTableNew->Columns->GetItem("ContactId")->Properties->GetItem("AutoIncrement")->Value = true;
89.   
90.   // 加入字段
91.   CString str;
92.   str = _T("公司名称");//"公司名称";
93.   pTableNew->Columns->Append(_variant_t(str), ADOCG::adVarWChar, 50);
94.         pTableNew->Columns->GetItem(_variant_t(str))->Properties->GetItem("Jet OLEDB:Allow Zero Length")->Value =false; //将必填字段设置为否
96.   str = _T("产品名称");//"产品名称";
97.   pTableNew->Columns->Append(_variant_t(str), ADOCG::adVarWChar, 50);
98.         pTableNew->Columns->GetItem(_variant_t(str))->Properties->GetItem("Jet OLEDB:Allow Zero Length")->Value =false;
100.   str = _T("产品规格");//"产品名称";
101.   pTableNew->Columns->Append(_variant_t(str), ADOCG::adVarWChar, 50);
102.         pTableNew->Columns->GetItem(_variant_t(str))->Properties->GetItem("Jet OLEDB:Allow Zero Length")->Value =false;
104.      //*      
105.   // 加入主键
106.   pIndexNew->Name = "pryIndex";//"日期";
107.   pIndexNew->Columns->Append(_variant_t(str), ADOCG::adVarWChar, 50);         
108.         
109.         pIndexNew->PutPrimaryKey(-1);
110.         pIndexNew->PutUnique(-1);
111.         pTableNew->Indexes->Append(_variant_t ((IDispatch*)pIndexNew));
112.   //*/
113.      
114.   // 加入表中
115.         pCatalog->Tables->Append(_variant_t ((IDispatch*)pTableNew));        
116.         pCatalog->Tables->Refresh();
117.   
118.     }
119.     catch(_com_error &e)
120.     {
121.         _bstr_t bstrSource(e.Source());
122.         _bstr_t bstrDescription(e.Description());
123.   AfxMessageBox(e.Description());
124.   return FALSE;
125.    
126.     }
128.  return TRUE;
129. }
131. //4.判断一个表在数据库中是否存在
133. BOOL CDeRenDlg::IsTalbeExit(CString strTable)
134. {
135.  try 
136.  { 
137.   if(!m_adoConnection.IsOpen()) return FALSE;
138.   
139.   _RecordsetPtr   pRstSchema   =   NULL;
141.   pRstSchema=m_adoConnection.OpenSchema(adSchemaTables);
142.   
143.   while(!pRstSchema->adoEOF) 
144.   { 
145.    _bstr_t table_name = pRstSchema->Fields->GetItem("TABLE_NAME")->Value;
146.    _bstr_t table_type = pRstSchema->Fields->GetItem("TABLE_TYPE")->Value;
147.    if ( strcmp(((LPCSTR)table_type),"TABLE")==0)
148.    {
149.     if(strTable.Compare((LPCSTR)table_name)==0)return  true;
150.    } 
151.   
152.    pRstSchema->MoveNext(); 
153.   }
154.   
155.   if(pRstSchema) pRstSchema->Close(); /*&&(pRstSchema->State==ADODB::adStateOpen)*/
156.  }
157.  catch(_com_error e)// 
158.  { 
159.   ::MessageBox(NULL,e.Description(),"Error",MB_OK);
160.   return FALSE;
161.  }
163.  return false;
165. }