// EmbeddedMySQL.h: interface for the CEmbeddedMySQL class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_EMBEDDEDMYSQL_H__516724E2_889C_4899_9DAE_330CD4C5954F__INCLUDED_)
#define AFX_EMBEDDEDMYSQL_H__516724E2_889C_4899_9DAE_330CD4C5954F__INCLUDED_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000
#include <mysql.h>
#include <string>
#include "StdString.h"
using namespace std;

//嵌入式MYSQL服务器
class CEmbeddedMySQL 
{
public:
 CEmbeddedMySQL();
 virtual ~CEmbeddedMySQL();

    static bool StartupEmbeddedServer();
    static void ShutdownEmbeddedServer();

    bool Open( const string &svr, const string &usr, const string &pwd, const string &db);
    void Close();

    bool ResetDB();
    void Set( const string &sField, const string &sValue );
    void Set( const string &sField, double dValue );
    void Set( const string &sField, long nValue );
    void Set( const string &sField, int nValue );
    void Set( const string &sField, BYTE *pBuf, int nLen );
    void SetNull( const string &sField );
    void registerOutParameter( const string &sField, char cType );
//    void SetRecord( const string &sField, const string &sTableName, const string &sTypeName, CStdRecord &Record );
  
    void Cmd(const char *cmd,...);
    bool More();
    long Exec();
//    bool SelectInto(CStdRecord *pRecord,bool bCreateHead=true);   
   
    double GetDouble(int id);
    double GetDouble(const string &name);
    long GetLong(int id);
    long GetLong(const string &name);
    string Get(int id);
    string Get(const string &name);
    string GetLastErrMsg();
    char* GetSql();

    bool MoreForUpdate();
    bool SetBuffer( int nFieldIndex, BYTE *pBuf, long nSize );
    bool SetBuffer( const string &sField, BYTE *pBuf, long nSize );
    bool GetBuffer( const string &sField, BYTE *pBuf, long &nSize );
    bool GetBuffer( int nFieldIndex, BYTE *pBuf, long &nSize );
    long GetDataSize( const string &sField );
    long GetDataSize( int nFieldIndex );
    long GetActualSize( const string &sField );
    long GetActualSize( int nFieldIndex );

    void ClearSql();
    long GetColIndex( const string &sField );
    string GetColName( int nFiledIndex );
    string GetColType( int index );
    int GetNumCols();
    string GetHeadScript();
   
    int  row_getsize();
    bool row_gethead( string &sHead );
    bool row_more( char *pData, int &nSize );   
   
    void SetAutoCommit( bool autoCommit );
    void RollBack();
    void Commit();
    bool IsDead();
    bool SetParam( int nType, const string &sVal );
protected:
 void WriteSQLErrLog();
 // 获取过程返回值
 string GetStorageProReturnValue(const