读写SQL Server的binary类型（VC/MFC）-阿里云开发者社区

读写SQL Server的binary类型（VC/MFC）

2017-11-11 1255

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

云数据库 RDS SQL Server，独享型 2核4GB

简介：

　以读写32位的IP地址为例。表的设计视图如下：

　　示例代码如下，其中CMSSADO为walker简单封装的类，不必关心，重点在代码中标注关键代码部分。为了减少代码，突出重点，代码中没有加入异常处理。walker的编译环境为win7 x64下vs2010，数据库为sql server 2008 R2。

 
        //初始化ADO环境
       
        AfxOleInit();
       
        CMSSADO mss_ado;
       
        CString str;
       
        CString conn_str = _T(
        "Provider=SQLOLEDB;"
        ); 
       
        conn_str += _T(
        "SERVER=127.0.0.1;"
        ); 
       
        conn_str += _T(
        "DATABASE=walker_test;"
        ); 
       
        conn_str += _T(
        "UID=sa;"
        ); 
       
        conn_str += _T(
        "PWD=xxxxxxx;"
        ); 
       
        mss_ado.OpenConnection(conn_str);
       
        ADODB::_ConnectionPtr conn = mss_ado.GetConnectionPtr();
       
        CString sql = _T(
        "INSERT INTO IPTbl(UserIP) VALUES(0x11223344)"
        );   
        //插入 
       
        conn->Execute((_bstr_t)sql, NULL, ADODB::adCmdText);
       
        sql = _T(
        "SELECT TOP 1 [UserID], [UserIP] FROM IPTbl"
        ); 
        //读取 
       
        ADODB::_RecordsetPtr rs = NULL;
       
        mss_ado.OpenRecordset(sql);
       
        rs = mss_ado.GetRecordsetPtr();
       
        CString UserID = _T(
        ""
        ), 
       
        UserIP = _T(
        ""
        ); 
       
        if 
        (!rs->adoEOF) 
       
        {
       
        _variant_t vUserID = rs->GetCollect(
        "UserID"
        ); 
       
        _variant_t vUserIP = rs->GetCollect(
        "UserIP"
        ); 
       
        UserID = (
        TCHAR
        *)(_bstr_t)(vUserID); 
       
        ///// begin 关键代码 ///// 
       
        char 
        *pBuf = NULL; 
       
        char 
        bytmp[4]; 
       
        memset
        (bytmp, 0, 
        sizeof
        (bytmp)); 
       
        SafeArrayAccessData(vUserIP.parray, (
        void 
        **)&pBuf); 
       
        if 
        (pBuf != NULL) 
       
        { 
       
        memcpy
        (bytmp, pBuf, 
        sizeof
        (bytmp)); 
       
        } 
       
        SafeArrayUnaccessData (vUserIP.parray); 
       
        wchar_t 
        wc; 
       
        CString s; 
       
        for
        (
        int 
        i=0; i<4; i++) 
       
        { 
       
        //因为是unicode环境，需要转换char为wchar_t 
       
        mbtowc
        (&wc, (
        char 
        *)&bytmp[i], MB_LEN_MAX); 
       
        s.Format(_T(
        "%X"
        ), wc); 
       
        UserIP += s; 
       
        } 
       
        ///// end 关键代码 ///// 
       
        AfxMessageBox(_T(
        "UserIP: "
        ) + UserIP); 
       
        }
       
        sql = _T(
        "UPDATE IPTbl SET UserIP=0x"
        ) + UserIP + _T(
        " WHERE UserID="
        ) + UserID;    
        //修改 
       
        conn->Execute((_bstr_t)sql, NULL, ADODB::adCmdText);
       
        //关闭ado环境
       
        AfxOleTerm();
       
        AfxMessageBox(_T(
        "OK"
        ));