位图保存到数据库 VC ado 类

VC数据库操作类(ado)---头文件部分

(2008-04-11 12:16:10)

转载

标签： mfc vc 数据库 位图 文件存储 hbitmap ado 访问 连接 it

分类： c++

特别提醒：
1.使用者只需要看懂头文件就OK了，不管你访问的是什么数据库，只需要修改源文件划线部分的连接部分就OK,如果你是用access,只需要改变数据库名就OK
2.数据库文件：需要放在应用程序所在地的data文件夹下
3.有兴趣的朋友课以去研究一下源文件，做一些功能拓展，其实我也是在网上查资料然后拓展的。欢迎跟本人联系：[e-mail]
头文件：ADOConn.h








// ADOConn.h: interface for the ADOConn class.
//
//////////////////////////////////////////////////////////////////////

#import "C:\Program Files\Common Files\System\ado\msado15.dll" no_namespace rename("EOF","adoEOF") rename("BOF","adoBOF")
//文件信息结构体
struct File
{
char* m_pBuffer;
int len;
};
#if !defined(AFX_ADOCONN_H__AC448F02_AF26_45E4_9B2D_D7ECB8FFCFB9__INCLUDED_)
#define AFX_ADOCONN_H__AC448F02_AF26_45E4_9B2D_D7ECB8FFCFB9__INCLUDED_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000

class ADOConn
{
// 定义变量
public:
 //添加一个指向Connection对象的指针:
_ConnectionPtr m_pConnection;
//添加一个指向Recordset对象的指针:
_RecordsetPtr m_pRecordset;
// 定义方法
public:
  //是否为位图文件
BOOL IsBMPFile(char* m_pBuffer);
//由位图的缓冲区转换为位图句柄
HBITMAP CharToHbitmap(char* m_pBuffer,CWnd* pwnd);
//获得数据库的OLE文件
//sql：定位到要获得的OLE对象的行的SQL语句
//name:OLE对象字段名
char* GetFileFromData(CString sql,CString name);
//把文件存入数据库
//af：文件信息
//sql:定位到要存储到的OLE对象的行的SQL语句
//name:OLE对象字段名
void CharToData(File &af,CString sql,CString Name);
//从计算机上获得你需要的文件
File GetFile();
ADOConn();
virtual ~ADOConn();
// 初始化—连接数据库
void  OnInitADOConn();
// 执行查询
_RecordsetPtr& GetRecordSet(_bstr_t bstrSQL);
 // 执行SQL语句，Insert Update _variant_t
BOOL ExecuteSQL(_bstr_t bstrSQL);
//停止与数据库的连接
void ExitConnect();
};

#endif // !defined(AFX_ADOCONN_H__AC448F02_AF26_45E4_9B2D_D7ECB8FFCFB9__INCLUDED_)

VC数据库操作类(ado)---源文件部分

(2008-04-11 13:38:28)

转载

标签： 文件存储 位图 vc mfc hbitmap ado 访问 it

分类： c++

 源文件：ADOConn.cpp

// ADOConn.cpp: implementation of the ADOConn class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "ADOConn.h"

#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////


ADOConn::ADOConn()
{
    OnInitADOConn();

}

ADOConn::~ADOConn()
{

}

// 初始化—连接数据库
void  ADOConn::OnInitADOConn()
{
    // 初始化OLE/COM库环境
    ::CoInitialize(NULL);
 
    try
    {
        // 创建Connection对象
        m_pConnection.CreateInstance("ADODB.Connection");
        TCHAR szFilePath[MAX_PATH + 1];
    GetModuleFileName(NULL, szFilePath, MAX_PATH);
    (_tcsrchr(szFilePath, _T('\\')))[1] = 0;//删除文件名，只获得路径。
    CString dbpath= szFilePath;
        // 设置连接字符串，必须是BSTR型或者_bstr_t类型
        _bstr_t strConnect = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source="+dbpath+"data\\数据库名.mdb";
            //SQL Server:strConnect ="Provider=SQLOLEDB;Server=HAPPY-MMNL94O2E\OPENSURF;Database=HR;uid=HAPPY-MMNL94O2E\Administrator;pwd=jj";
        m_pConnection->Open(strConnect,"","",adModeUnknown);
    }
    // 捕捉异常
    catch(_com_error e)
    {
        // 显示错误信息
        AfxMessageBox(e.Description());
    }
}

// 执行查询
_RecordsetPtr&  ADOConn::GetRecordSet(_bstr_t bstrSQL)
{

    try
    {
        // 连接数据库，如果Connection对象为空，则重新连接数据库
        if(m_pConnection==NULL)
            OnInitADOConn();
        // 创建记录集对象
        m_pRecordset.CreateInstance(__uuidof(Recordset));
        // 取得表中的记录
        m_pRecordset->Open(bstrSQL,m_pConnection.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText);
    }
    // 捕捉异常
    catch(_com_error e)
    {
        // 显示错误信息
        AfxMessageBox(e.Description());
    }
    // 返回记录集
    return m_pRecordset;
}

 // 执行SQL语句，Insert Update _variant_t
BOOL ADOConn::ExecuteSQL(_bstr_t bstrSQL)
{
//    _variant_t RecordsAffected;
    try
    {
        // 是否已经连接数据库
        if(m_pConnection == NULL)
            OnInitADOConn();
        // Connection对象的Execute方法:(_bstr_t CommandText,
        // VARIANT * RecordsAffected, long Options )
        // 其中CommandText是命令字串，通常是SQL命令。
        // 参数RecordsAffected是操作完成后所影响的行数,
        // 参数Options表示CommandText的类型：adCmdText-文本命令；adCmdTable-表名
        // adCmdProc-存储过程；adCmdUnknown-未知
        m_pConnection->Execute(bstrSQL,NULL,adCmdText);
        return true;
    }
    catch(_com_error e)
    {
        AfxMessageBox(e.Description());
        return false;
    }
}

void ADOConn::ExitConnect()
{
    // 关闭记录集和连接
    if (m_pRecordset != NULL)
        m_pRecordset->Close();
    m_pConnection->Close();
    // 释放环境
    ::CoUninitialize();
}

File ADOConn::GetFile()
{
    File af;
    af.len=0;
    af.m_pBuffer=NULL;
        static char BASED_CODE szFilter[] = "BMP Files (*.bmp)|*.bmp|All Files (*.*)|*.*||";
    CFileDialog dlg(TRUE,"BMP",NULL,  OFN_HIDEREADONLY | OFN_OVERWRITEPROMPT,szFilter);
    if(dlg.DoModal() != IDOK)
        return af;

    CString pathname = dlg.GetPathName();
     //从BMP文件中读取的数据存放在此变量中
   
    //@@@@@@@@@@   读取BMP文件到m_pBuffer   @@@@@@@@@@
    CFile file;  //定义文件对象
    if( !file.Open(pathname, CFile::modeRead)) //以只读方式打开文件
    {
        AfxMessageBox("无法打开BMP文件");
        return af;
    }
    DWORD m_filelen;  //用于保存文件长度
    m_filelen = file.GetLength();  //读取文件长度
    af.len=m_filelen;
    af.m_pBuffer = new char[m_filelen + 1]; //根据文件长度分配数组空间
    if(!af.m_pBuffer)  //如果不空间不足则返回
    {
        AfxMessageBox("无法分配足够的内存空间");
        return af;
    }
    if(file.ReadHuge(af.m_pBuffer, m_filelen) != m_filelen)  //读取BMP文件到m_pBuffer中
    {
        AfxMessageBox("读取文件时出现错误");
        return af;
    }
   
    return af;

}

void ADOConn::CharToData(File &af,CString sql,CString Name)
{
    //@@@@@@@@@@@  将图像数据保存到数据库中  @@@@@@@@@@@@@
    OnInitADOConn();
    //连接数据库
    OnInitADOConn();
    //设置SELECT语句
   
    //执行SELETE语句
    _RecordsetPtr    m_pRs;
   
    m_pRs =GetRecordSet(_bstr_t(sql));   
 
    VARIANT            varBLOB;
    SAFEARRAY        *psa;  //定义数组
    SAFEARRAYBOUND    rgsabound[1];

    rgsabound[0].lLbound = 0;
    int flen=af.len;
   
    rgsabound[0].cElements =flen;
   
    psa = SafeArrayCreate(VT_UI1, 1, rgsabound);//创建数组
    for (long i = 0; i < (long)flen; i++)  //将m_pBuffer中的图像数据写入数组psa
        SafeArrayPutElement (psa, &i, af.m_pBuffer++);
    varBLOB.vt = VT_ARRAY | VT_UI1;
    varBLOB.parray = psa;
    //调用AppendChunk()函数将图像数据写入Photo字段
    m_pRs->GetFields()->GetItem((LPCSTR)Name)->AppendChunk(varBLOB);
    //更新数据库
    m_pRs->Update();
    //断开与数据库的连接
    ExitConnect();

}

char* ADOConn::GetFileFromData(CString sql, CString name)
{
   
        //执行SELETE语句
        _RecordsetPtr    m_pRs;
        m_pRs =GetRecordSet(_bstr_t(sql));   

        //如果不存在此记录，则将设置按钮置灰并返回
        if(m_pRs->adoEOF || m_pRs->adoBOF) 
        {
            AfxMessageBox("不存在此记录");
            return FALSE;
        }
        //读取图像字段的实际大小
        long lDataSize = m_pRs->GetFields()->GetItem((LPCSTR)name)->ActualSize;
        if(lDataSize==NULL||lDataSize==0)
        {
            AfxMessageBox("字段为空");
            return NULL;
        }
        char *m_pBuffer;  //定义缓冲变量
        if(lDataSize > 0)
        {
            //从图像字段中读取数据到varBLOB中
            _variant_t varBLOB;
            varBLOB = m_pRs->GetFields()->GetItem((LPCSTR)name)->GetChunk(lDataSize);
            if(varBLOB.vt == (VT_ARRAY | VT_UI1))
            {
                if(m_pBuffer = new char[lDataSize+1])    //分配必要的存储空间
                {   
                    char *pBuf = NULL;
                    SafeArrayAccessData(varBLOB.parray,(void **)&pBuf);
                    memcpy(m_pBuffer,pBuf,lDataSize); ///复制数据到缓冲区m_pBuffer
                    SafeArrayUnaccessData (varBLOB.parray);
                   
                }
            }
        }
       
        return m_pBuffer;

}

HBITMAP ADOConn::CharToHbitmap(char* m_pBuffer,CWnd* pwnd)
{
   
                    LPSTR hDIB;
                    LPVOID lpDIBBits;
                    HBITMAP m_hBitmap;
                    BITMAPFILEHEADER bmfHeader;  //用于保存BMP文件头信息，包括类型、大小、位移量等
                    DWORD bmfHeaderLen;  //保存文件头的长度

                    bmfHeaderLen = sizeof(bmfHeader);  //读取文件头的长度
                    //将m_pBuffer中文件头复制到bmfHeader中
                   
                    strncpy((LPSTR)&bmfHeader, (LPSTR)m_pBuffer, bmfHeaderLen);
                    if (bmfHeader.bfType != (*(WORD*)"BM"))   //如果文件类型不对，则返回
                    {
                        AfxMessageBox("BMP文件格式不准确");
                        return NULL;
                    }
               
                    hDIB = m_pBuffer + bmfHeaderLen;  //将指针移至文件头后面
                    //读取BMP文件的图像数据，包括坐标及颜色格式等信息到BITMAPINFOHEADER对象
                    BITMAPINFOHEADER &bmiHeader = *(LPBITMAPINFOHEADER)hDIB;
                    //读取BMP文件的图像数据，包括坐标及颜色格式等信息到BITMAPINFO对象
                    BITMAPINFO &bmInfo = *(LPBITMAPINFO)hDIB ;
                    //根据bfOffBits属性将指针移至文件头后
                    lpDIBBits = (m_pBuffer) + ((BITMAPFILEHEADER *)m_pBuffer)->bfOffBits;
                     CClientDC dc(pwnd);   //生成一个与当前窗口相关的CClientDC，用于管理输出设置
                    //生成DIBitmap数据
                    m_hBitmap = CreateDIBitmap(dc.m_hDC,&bmiHeader,CBM_INIT,lpDIBBits,&bmInfo,DIB_RGB_COLORS);
                   
                    return m_hBitmap;
               

}

BOOL ADOConn::IsBMPFile(char *m_pBuffer)
{
    BOOL bl=TRUE;
   
    BITMAPFILEHEADER bmfHeader;  //用于保存BMP文件头信息，包括类型、大小、位移量等
    DWORD bmfHeaderLen;  //保存文件头的长度

    bmfHeaderLen = sizeof(bmfHeader);  //读取文件头的长度
    //将m_pBuffer中文件头复制到bmfHeader中
    strncpy((LPSTR)&bmfHeader, (LPSTR)m_pBuffer, bmfHeaderLen);    
    if (bmfHeader.bfType != (*(WORD*)"BM"))   //如果文件类型不对，则返回
    bl=FALSE;
    return bl;

}