开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
connect.c
资源名称：myodbc-2_50_17a-src.zip　[点击查看]
上传用户：jmzj888
上传日期：2007-01-02
资源大小：220k
文件大小：17k
源码类别：

MySQL数据库

开发平台：

Visual C++

connect.c：源码内容
  1. /* Copyright Abandoned 1997 TCX DataKonsult AB & Monty Program KB & Detron HB
  2.    This file is public domain and comes with NO WARRANTY of any kind */
  4. /*
  5. ** CONNECT.C - This is the ODBC sample driver code for
  6. ** allocation and connection.
  7. */
  9. #include "myodbc.h"
  11. #ifndef _UNIX_
  12. #include <odbcinst.h>
  13. #include "dialogs.h"
  14. #endif /* IS NOT UNIX */
  16. #ifndef CLIENT_NO_SCHEMA /* Temporary fix for 3.21.29 */
  17. #define CLIENT_NO_SCHEMA      16
  18. #endif
  20. //      CONNECT.C
  21. //
  22. //      SQLC connection functions.
  23. //      -       -       -       -       -       -       -       -       -
  24. //      Allocate an environment (ENV) block.
  27. RETCODE SQL_API SQLAllocEnv(HENV FAR * phenv)
  28. {
  29.   myodbc_init();
  30. #ifndef _UNIX_
  31.   {
  32.     HGLOBAL henv= GlobalAlloc (GMEM_MOVEABLE | GMEM_ZEROINIT, sizeof (ENV));
  33.     if (henv == NULL || (*phenv = (HENV)GlobalLock (henv)) == NULL)
  34.     {
  35.       GlobalFree (henv); /* Free it if lock fails */
  36.       *phenv = SQL_NULL_HENV;
  37.       return SQL_ERROR;
  38.     }
  39.   }
  40. #else
  41.   if (!(*phenv = (HENV) my_malloc(sizeof(ENV),MYF(MY_ZEROFILL))))
  42.   {
  43.     *phenv = SQL_NULL_HENV;
  44.     return SQL_ERROR;
  45.   }
  46. #endif /* IS UNIX */
  47.   return SQL_SUCCESS;
  48. }
  51. RETCODE SQL_API SQLFreeEnv(HENV henv)
  52. {
  53. #ifndef _UNIX_
  54.   GlobalUnlock(GlobalHandle((HGLOBAL) henv));
  55.   GlobalFree(GlobalHandle((HGLOBAL) henv));
  56. #else
  57.   my_free(henv,MYF(0));
  58. #endif /* IS UNIX */
  59.   return SQL_SUCCESS;
  60. }
  63. //      -       -       -       -       -       -       -       -       -
  64. //      Allocate a DBC block.
  66. RETCODE SQL_API SQLAllocConnect(HENV henv, HDBC FAR *phdbc)
  67. {
  68.   DBC FAR *dbc;
  69. #ifndef _UNIX_
  70.   {
  71.     HGLOBAL hdbc = GlobalAlloc (GMEM_MOVEABLE | GMEM_ZEROINIT, sizeof (DBC));
  72.     if (!hdbc || (*phdbc = (HDBC)GlobalLock (hdbc)) == SQL_NULL_HDBC)
  73.     {
  74.       GlobalFree (hdbc); /* Free it if lock fails */
  75.       *phdbc = SQL_NULL_HENV;
  76.       return SQL_ERROR;
  77.     }
  78.   }
  79. #else /* IS UNIX */
  80.   if (!(*phdbc = (HDBC) my_malloc(sizeof(DBC),MYF(MY_ZEROFILL))))
  81.   {
  82.     *phdbc = SQL_NULL_HDBC;
  83.     return SQL_ERROR;
  84.   }
  85. #endif
  87.   dbc=(DBC FAR*) *phdbc;
  88.   dbc->env=henv;
  89.   dbc->mysql.net.fd = -1; /* Marker if open */
  90.   dbc->flag=0;
  91.   dbc->stmt_options.max_rows= dbc->stmt_options.max_length= 0L;
  92.   dbc->stmt_options.bind_type=SQL_BIND_BY_COLUMN;
  93.   dbc->stmt_options.rows_in_set=1;
  94.   dbc->stmt_options.cursor_type=SQL_CURSOR_FORWARD_ONLY;  /* ODBC default */
  95.   dbc->login_timeout=0;
  96.   return SQL_SUCCESS;
  97. }
  100. RETCODE SQL_API SQLFreeConnect(HDBC hdbc)
  101. {
  102.   DBC FAR *dbc=(DBC FAR*) hdbc;
  103.   my_free(dbc->dsn,MYF(MY_ALLOW_ZERO_PTR));
  104.   my_free(dbc->database,MYF(MY_ALLOW_ZERO_PTR));
  105.   my_free(dbc->server,MYF(MY_ALLOW_ZERO_PTR));
  106.   my_free(dbc->user,MYF(MY_ALLOW_ZERO_PTR));
  107.   my_free(dbc->password,MYF(MY_ALLOW_ZERO_PTR));
  109. #ifndef _UNIX_
  110.   GlobalUnlock(GlobalHandle((HGLOBAL) hdbc));
  111.   GlobalFree(GlobalHandle((HGLOBAL) hdbc));
  112. #else  /* IS UNIX */
  113.   my_free(hdbc,MYF(0));
  114. #endif
  115.   return SQL_SUCCESS;
  116. }
  118. /******************************************************************************
  119. * Connect to mysql server
  120. ******************************************************************************/
  122. RETCODE SQL_API SQLConnect(HDBC hdbc, UCHAR FAR *szDSN, SWORD   cbDSN,
  123.    UCHAR FAR *szUID, SWORD cbUID, UCHAR FAR *szAuthStr,
  124.    SWORD cbAuthStr)
  125. {
  126.   char host[64],user[64],passwd[64],dsn[NAME_LEN+1],database[NAME_LEN+1],
  127.        port[10],flag[10];
  128.   uint port_nr=0,flag_nr=0,client_flag=0;
  129.   DBC FAR *dbc=(DBC FAR*) hdbc;
  130.   DBUG_ENTER("SQLConnect");
  132.   if (dbc->mysql.net.fd >= 0)
  133.   {
  134.     DBUG_RETURN(set_error(hdbc,"08002","Connection in use",0));
  135.   }
  136.   dbc->sqlstate[0]=0;
  137. #ifndef _UNIX_
  138.   SQLGetPrivateProfileString(fix_str(dsn,szDSN,cbDSN),"server",
  139.      "localhost", host, sizeof(host),"ODBC.INI");
  140.   SQLGetPrivateProfileString(dsn,"database",
  141.      dsn, database, sizeof(database),"ODBC.INI");
  142.   SQLGetPrivateProfileString(dsn,"port",
  143.      "0", port, sizeof(port),"ODBC.INI");
  144.   port_nr=(uint) atoi(port);
  145.   SQLGetPrivateProfileString(dsn,"flag",
  146.      "0", flag, sizeof(flag),"ODBC.INI");
  147.   flag_nr=(uint) atoi(flag);
  148. #else
  149.   strmov(database,szDSN);
  150.   {
  151.     char *cp;
  152.     strmov(host, (cp = getenv("MYSQL_HOST")) ? cp : "localhost");
  153.   }
  154. #endif /* IS UNIX */
  156.   if (flag_nr & FLAG_FOUND_ROWS)
  157.     client_flag=CLIENT_FOUND_ROWS;
  158.   if (flag_nr & FLAG_NO_SCHEMA)
  159.     client_flag|=CLIENT_NO_SCHEMA;
  160.   if (flag_nr & FLAG_DEBUG)
  161.     mysql_debug("d:t:S:O,c::\myodbc.log");
  162.   DBUG_PRINT("info",("MyODBC Version %s  Options: %d",DRIVER_VERSION,flag_nr));
  163.   if (flag_nr & FLAG_BIG_PACKETS)
  164.     max_allowed_packet=~0L;
  165. #if MYSQL_VERSION_ID >= 32200
  166.   if (!mysql_real_connect(&dbc->mysql,host,fix_str(user,(char FAR *) szUID,
  167.    cbUID),
  168.   fix_str(passwd,(char FAR*) szAuthStr,cbAuthStr),
  169.   database, port_nr,
  170.   NullS, client_flag))
  171.   {
  172.     strmov(dbc->sqlstate,"S1000");
  173.     DBUG_RETURN(SQL_ERROR);
  174.   }
  175. #else
  176.   if (!mysql_real_connect(&dbc->mysql,host,fix_str(user,(char FAR *) szUID,
  177.    cbUID),
  178.   fix_str(passwd,(char FAR*) szAuthStr,cbAuthStr),
  179.   port_nr, NullS, client_flag))
  180.   {
  181.     strmov(dbc->sqlstate,"S1000");
  182.     DBUG_RETURN(SQL_ERROR);
  183.   }
  184.   if (mysql_select_db(&dbc->mysql,database))
  185.   {
  186.     strmov(dbc->sqlstate,"08004");
  187.     mysql_close(&dbc->mysql);
  188.     DBUG_RETURN(SQL_ERROR);
  189.   }
  190. #endif
  191.   dbc->dsn=my_strdup(database,MYF(MY_WME));
  192.   dbc->database=my_strdup(database,MYF(MY_WME));
  193.   dbc->server=my_strdup(host,MYF(MY_WME));
  194.   dbc->user=my_strdup(user,MYF(MY_WME));
  195.   dbc->password=my_strdup(passwd,MYF(MY_WME));
  196.   dbc->port=port_nr;
  197.   dbc->flag=flag_nr;
  198.   DBUG_RETURN(SQL_SUCCESS);
  199. }
  202. // This function as its "normal" behavior is supposed to bring up a
  203. // dialog box if it isn't given enough information via "szConnStrIn".  If
  204. // it is given enough information, it's supposed to use "szConnStrIn" to
  205. // establish a database connection.  In either case, it returns a
  206. // string to the user that is the string that was eventually used to
  207. // establish the connection.
  209. #ifdef _UNIX_ /* By Tsurng-Chen Chern */
  210. char *my_strtok(char *s1, char *s2)
  211. {
  212.    char *start;
  213.    static char *p;
  215.    p = (s1 ? s1 : p + 1);
  216.    if ((!p) || (!*p))
  217.       return(NULL);
  219.    start = p;
  220.    while ((*p) && (!strchr(s2, *p)))
  221.       p++;
  222.    *p = 0;
  223.    return(start);
  224. }
  225. #endif
  228. RETCODE SQL_API SQLDriverConnect(HDBC hdbc,HWND hwnd,UCHAR FAR *szConnStrIn,
  229.  SWORD cbConnStrIn,UCHAR FAR *szConnStrOut,
  230.  SWORD cbConnStrOutMax,
  231.  SWORD FAR *pcbConnStrOut,
  232.  UWORD fDriverCompletion)
  233. {
  234. #ifndef _UNIX_
  236.   short   iRet;
  237.   BOOL    fPrompt = FALSE,maybe_prompt;
  238.   DBC FAR *dbc=(DBC FAR*) hdbc;
  239.   GLOBALHANDLE hglbAttr;
  240.   LPSETUPDLG lpsetupdlg;
  241.   uint client_flag=0;
  242.   DBUG_ENTER("SQLDriverConnect");
  243.   DBUG_PRINT("enter",("fDriverCompletion: %d",fDriverCompletion));
  245.   hglbAttr = GlobalAlloc(GMEM_MOVEABLE | GMEM_ZEROINIT, sizeof(SETUPDLG));
  246.   if (!hglbAttr)
  247.     DBUG_RETURN(FALSE);
  248.   lpsetupdlg = (LPSETUPDLG)GlobalLock(hglbAttr);
  250.   maybe_prompt=(fDriverCompletion == SQL_DRIVER_COMPLETE ||
  251. fDriverCompletion == SQL_DRIVER_COMPLETE_REQUIRED);
  252.   if ((szConnStrIn == NULL) || (!cbConnStrIn) ||
  253.       ((cbConnStrIn == SQL_NTS) && (!szConnStrIn[0])))
  254.     fPrompt = TRUE;
  255.   else
  256.   {
  257.     int flag;
  258.     /* Check connection string for completeness. Prompt if not all params */
  259.     ParseAttributes(szConnStrIn, lpsetupdlg);
  260.     set_attributes(lpsetupdlg);
  261.     flag=atoi(lpsetupdlg->aAttr[KEY_FLAG].szAttr);
  262.     if (fDriverCompletion == SQL_DRIVER_PROMPT && ! (flag & FLAG_NO_PROMPT) ||
  263. (maybe_prompt &&
  264.  (!lpsetupdlg->aAttr[KEY_DSN].szAttr[0] ||
  265.   !lpsetupdlg->aAttr[KEY_SERVER].szAttr[0] ||
  266.   !lpsetupdlg->aAttr[KEY_USER].szAttr[0])))
  267.       fPrompt = TRUE;
  268.   }
  269. retry:
  270.   if (fPrompt)
  271.   {
  272.     iRet = DialogBoxParam(s_hModule, MAKEINTRESOURCE(DRIVERCONNECT), hwnd,
  273.           DriverConnectProc,
  274.           (LONG)(LPSTR) lpsetupdlg);
  275.     if ((!iRet) || (iRet == -1))
  276.     {
  277.       GlobalUnlock(hglbAttr);
  278.       GlobalFree(hglbAttr);
  279.       DBUG_RETURN(SQL_NO_DATA_FOUND);
  280.     }
  281.   }
  282.   if (szConnStrOut)
  283.   {
  284.     char *pos,buff[1024];
  285.     long length;
  286.     ulong tmp= ~0L;
  287.     pos=strxmov(buff,
  288. "DSN=",lpsetupdlg->aAttr[KEY_DSN].szAttr,
  289. ";DB=",lpsetupdlg->aAttr[KEY_DB].szAttr,
  290. ";SERVER=",lpsetupdlg->aAttr[KEY_SERVER].szAttr,
  291. ";UID=",lpsetupdlg->aAttr[KEY_USER].szAttr,
  292. ";PWD=",lpsetupdlg->aAttr[KEY_PASSWORD].szAttr,
  293. ";PORT=",lpsetupdlg->aAttr[KEY_PORT].szAttr,
  294. ";FLAG=",lpsetupdlg->aAttr[KEY_FLAG].szAttr,
  295. ";",NullS);
  296.     (void) copy_lresult((DBC FAR*) 0,szConnStrOut,cbConnStrOutMax,
  297.                         &length,buff,(uint) (pos-buff),0L,0L,&tmp);
  298.     if (pcbConnStrOut)
  299.       *pcbConnStrOut=(SWORD) length;
  300.     DBUG_PRINT("info",("Connect string out: %s",szConnStrOut));
  301.   }
  302.   dbc->port=atoi(lpsetupdlg->aAttr[KEY_PORT].szAttr);
  303.   dbc->flag=atoi(lpsetupdlg->aAttr[KEY_FLAG].szAttr);
  304.   if (dbc->flag & FLAG_FOUND_ROWS)
  305.     client_flag=CLIENT_FOUND_ROWS;
  306.    if (dbc->flag & FLAG_NO_SCHEMA)
  307. client_flag|=CLIENT_NO_SCHEMA;
  308.   if (dbc->flag & FLAG_DEBUG)
  309.     mysql_debug("d:t:S:O,c::\myodbc.log");
  310.   DBUG_PRINT("info",("MyODBC Version %s  Options: %d",DRIVER_VERSION,
  311.      dbc->flag));
  312.   if (dbc->flag & FLAG_BIG_PACKETS)
  313.     max_allowed_packet=~0L;
  315.   /* If no DB, use DSN as database name */
  316.   if (!lpsetupdlg->aAttr[KEY_DB].szAttr[0])
  317.   {
  318.     strmov(lpsetupdlg->aAttr[KEY_DB].szAttr,
  319.    lpsetupdlg->aAttr[KEY_DSN].szAttr);
  320.   }
  321.   if (!mysql_real_connect(&dbc->mysql,lpsetupdlg->aAttr[KEY_SERVER].szAttr,
  322.   lpsetupdlg->aAttr[KEY_USER].szAttr,
  323.   lpsetupdlg->aAttr[KEY_PASSWORD].szAttr,
  324.   lpsetupdlg->aAttr[KEY_DB].szAttr,
  325.   dbc->port,NullS,client_flag))
  326.   {
  327.     if (maybe_prompt && !fPrompt)
  328.     {
  329.       fPrompt=TRUE;
  330.       goto retry;
  331.     }
  332.     strmov(dbc->sqlstate,"S1000");
  333.     GlobalUnlock(hglbAttr);
  334.     GlobalFree(hglbAttr);
  335.     DBUG_RETURN(SQL_ERROR);
  336.   }
  337.   dbc->dsn=my_strdup(lpsetupdlg->aAttr[KEY_DSN].szAttr,MYF(MY_WME));
  338.   dbc->database=my_strdup(lpsetupdlg->aAttr[KEY_DB].szAttr,MYF(MY_WME));
  339.   dbc->server=my_strdup(lpsetupdlg->aAttr[KEY_SERVER].szAttr,MYF(MY_WME));
  340.   dbc->user=my_strdup(lpsetupdlg->aAttr[KEY_USER].szAttr,MYF(MY_WME));
  341.   dbc->password=my_strdup(lpsetupdlg->aAttr[KEY_PASSWORD].szAttr,MYF(MY_WME));
  343.   GlobalUnlock(hglbAttr);
  344.   GlobalFree(hglbAttr);
  345.   DBUG_RETURN(SQL_SUCCESS);
  346. #endif /* IS NOT UNIX */
  348. #ifdef _UNIX_
  349.   UCHAR FAR *connstrin=NULL;
  350.   char *KEY_DSN=NULL;
  351.   char *KEY_SERVER=NULL;
  352.   char *KEY_USER=NULL;
  353.   char *KEY_PASSWORD=NULL;
  354.   char *KEY_PORT=NULL;
  355.   char *KEY_OPTION=NULL;
  356.   char *KEY_DB=NULL;
  357.   char *KEY_SOCKET=NULL;
  359.   char *tok[9];
  360.   char *tok2=NULL;
  361.   char *tok3=NULL;
  362.   int i;
  363.   uint client_flag=0;
  365.   BOOL    fPrompt = FALSE;
  366.   DBC FAR *dbc=(DBC FAR*) hdbc;
  367.   DBUG_ENTER("SQLDriverConnect");
  368.   DBUG_PRINT("enter",("fDriverCompletion: %d",fDriverCompletion));
  370.   if ((szConnStrIn == NULL) || (!cbConnStrIn) ||
  371.       ((cbConnStrIn == SQL_NTS) && (!szConnStrIn[0])))
  372.     fPrompt = TRUE;
  373.   else
  374.   {
  375.     /* Check connection string for completeness. */
  376.     /* Prompt if not all params  */
  378.     connstrin=(UCHAR FAR *) my_strdup(szConnStrIn,MYF(MY_WME));
  380.     tok[0]=my_strtok(connstrin,";");
  381.     for (i=1 ; i <= 7 ; i++)
  382.       tok[i]=my_strtok(NULL,";");
  383.     tok[i]=NULL;
  385.     for (i=0 ; tok[i] ; i++)
  386.     {
  387.       if (tok2 = my_strtok(tok[i], "="))
  388.       {
  389. if (strcmp("DSN", tok2) == 0)
  390. {
  391.   if ((tok3 = my_strtok(NULL, "")) && tok3[0])
  392.     KEY_DSN = (char*) my_strdup(tok3, MYF(MY_WME));
  393.   else
  394.   {
  395.     x_free(KEY_DSN);
  396.     KEY_DSN = NULL;
  397.   }
  398. }
  400. if (strcmp("DB", tok2) == 0)
  401. {
  402.   if ((tok3 = my_strtok(NULL, "")) && tok3[0])
  403.     KEY_DB = (char*) my_strdup(tok3, MYF(MY_WME));
  404.   else
  405.   {
  406.     x_free(KEY_DB);
  407.     KEY_DB = NULL;
  408.   }
  409. }
  411. if (strcmp("UID", tok2) == 0)
  412. {
  413.   if ((tok3 = my_strtok(NULL, "")) && tok3[0])
  414.     KEY_USER = (char*) my_strdup(tok3, MYF(MY_WME));
  415.   else
  416.   {
  417.     x_free(KEY_USER);
  418.     KEY_USER = NULL;
  419.   }
  420. }
  422. if (strcmp("PWD", tok2) == 0)
  423. {
  424.   if ((tok3 = my_strtok(NULL, "")) && tok3[0])
  425.     KEY_PASSWORD = (char*) my_strdup(tok3, MYF(MY_WME));
  426.   else
  427.   {
  428.     x_free(KEY_PASSWORD);
  429.     KEY_PASSWORD = NULL;
  430.   }
  431. }
  433. if (strcmp("SERVER", tok2) == 0)
  434. {
  435.   if ((tok3 = my_strtok(NULL, "")) && tok3[0])
  436.     KEY_SERVER = (char*) my_strdup(tok3, MYF(MY_WME));
  437.   else
  438.   {
  439.     x_free(KEY_SERVER);
  440.     KEY_SERVER = NULL;
  441.   }
  442. }
  444. if (strcmp("PORT", tok2) == 0)
  445. {
  446.   if ((tok3 = my_strtok(NULL, "")) && tok3[0])
  447.     KEY_PORT = (char*) my_strdup(tok3, MYF(MY_WME));
  448.   else
  449.   {
  450.     x_free(KEY_PORT);
  451.     KEY_PORT = NULL;
  452.   }
  453. }
  454. if (strcmp("SOCKET", tok2) == 0)
  455. {
  456.   if ((tok3 = my_strtok(NULL, "")) && tok3[0])
  457.     KEY_SOCKET = (char*) my_strdup(tok3, MYF(MY_WME));
  458.   else
  459.   {
  460.     x_free(KEY_SOCKET);
  461.     KEY_PORT = NULL;
  462.   }
  463. }
  465. if (strcmp("OPTION", tok2) == 0)
  466. {
  467.   if ((tok3 = my_strtok(NULL, "")) && tok3[0])
  468.     KEY_OPTION = (char*) my_strdup(tok3, MYF(MY_WME));
  469.   else
  470.   {
  471.     x_free(KEY_OPTION);
  472.     KEY_PORT = NULL;
  473.   }
  474. }
  475.       }
  476.     }
  478.     if (!KEY_DB && KEY_DSN)
  479.       KEY_DB = (char*) my_strdup(KEY_DSN, MYF(MY_WME));
  481.     if (!KEY_SERVER)
  482.       KEY_SERVER = (char*) my_strdup("localhost", MYF(MY_WME));
  484.     if (!KEY_PORT)
  485.       KEY_PORT = (char*) my_strdup("3306", MYF(MY_WME));
  487.     if (!KEY_SOCKET)
  488.       KEY_SOCKET = (char*) my_strdup("", MYF(MY_WME));
  490.     if (!KEY_USER)
  491.       KEY_USER = (char*) my_strdup("dummy", MYF(MY_WME));
  493.     if (!KEY_PASSWORD)
  494.       KEY_PASSWORD = (char*) my_strdup("", MYF(MY_WME));
  496.     if (!KEY_OPTION)
  497.       KEY_OPTION = (char*) my_strdup("0", MYF(MY_WME));
  499.     if (fDriverCompletion == SQL_DRIVER_PROMPT ||
  500. ((fDriverCompletion == SQL_DRIVER_COMPLETE ||
  501.   fDriverCompletion == SQL_DRIVER_COMPLETE_REQUIRED) &&
  502.  (!KEY_DSN)))
  503.       fPrompt = TRUE;
  504.   }
  505.   if (fPrompt)
  506.   {
  507.     DBUG_RETURN(set_error((DBC FAR*) hdbc,"S1000","No DSN entered",0));
  508.   }
  510.   if (szConnStrOut)
  511.   {
  512.     UCHAR FAR  *pos;
  513.     pos=strxmov(szConnStrOut,
  514. "DSN=",KEY_DSN,
  515. ";DB=",KEY_DB,
  516.                 ";SERVER=",KEY_SERVER,
  517.                 ";UID=",KEY_USER,
  518.                 ";PWD=",KEY_PASSWORD,
  519.                 ";PORT=",KEY_PORT,
  520.                 ";SOCKET=",KEY_SOCKET,
  521.                 ";OPTION=",KEY_OPTION,
  522. ";",NullS);
  523.     *pcbConnStrOut=(int) (pos-szConnStrOut);
  524.   }
  525.   dbc->flag=atoi(KEY_OPTION);
  526.   dbc->port=atoi(KEY_PORT);
  527.   if (dbc->flag & FLAG_FOUND_ROWS)
  528.     client_flag=CLIENT_FOUND_ROWS;
  529.   if (dbc->flag & FLAG_NO_SCHEMA)
  530. client_flag|=CLIENT_NO_SCHEMA;
  531.   if (dbc->flag & FLAG_DEBUG)
  532.     mysql_debug("d:t:S:O,/tmp/myodbc.log");
  533.   DBUG_PRINT("info",("MyODBC Version %s  Options: %d",DRIVER_VERSION,
  534.      dbc->flag));
  535.   if (dbc->flag & FLAG_BIG_PACKETS)
  536.     max_allowed_packet=~0L;
  537. #if MYSQL_VERSION_ID >= 32200
  538.   if (!mysql_real_connect(&dbc->mysql,KEY_SERVER,
  539.   KEY_USER,
  540.   KEY_PASSWORD,
  541.                           KEY_DB,
  542.                           dbc->port,
  543.   KEY_SOCKET[0] ? KEY_SOCKET : NullS,
  544.   client_flag))
  545.   {
  546.     strmov(dbc->sqlstate,"S1000");
  547.     DBUG_RETURN(SQL_ERROR);
  548.   }
  549. #else
  550.   if (!mysql_real_connect(&dbc->mysql,KEY_SERVER,
  551.   KEY_USER,
  552.   KEY_PASSWORD,
  553.                           dbc->port,
  554.   KEY_SOCKET[0] ? KEY_SOCKET : NullS,
  555.   client_flag))
  556.   {
  557.     strmov(dbc->sqlstate,"S1000");
  558.     DBUG_RETURN(SQL_ERROR);
  559.   }
  560.   if (mysql_select_db(&dbc->mysql,KEY_DB))
  561.   {
  562.     strmov(dbc->sqlstate,"08004");
  563.     mysql_close(&dbc->mysql);
  564.     DBUG_RETURN(SQL_ERROR);
  565.   }
  566. #endif
  567.   dbc->dsn=my_strdup(KEY_DSN,MYF(MY_WME));
  568.   dbc->database=my_strdup(KEY_DB,MYF(MY_WME));
  569.   dbc->server=my_strdup(KEY_SERVER,MYF(MY_WME));
  570.   dbc->user=my_strdup(KEY_USER,MYF(MY_WME));
  571.   dbc->password=my_strdup(KEY_PASSWORD,MYF(MY_WME));
  573.   x_free(KEY_DSN);
  574.   x_free(KEY_DB);
  575.   x_free(KEY_SERVER);
  576.   x_free(KEY_USER);
  577.   x_free(KEY_PASSWORD);
  578.   x_free(KEY_PORT);
  579.   x_free(KEY_SOCKET);
  580.   x_free(KEY_OPTION);
  581.   x_free(connstrin);
  583.   DBUG_RETURN(SQL_SUCCESS);
  584. #endif /* IS UNIX */
  585. }
  588. RETCODE SQL_API SQLBrowseConnect(HDBC hdbc,UCHAR FAR *szConnStrIn,
  589.  SWORD cbConnStrIn,
  590.  UCHAR FAR *szConnStrOut,SWORD cbConnStrOutMax,
  591.  SWORD FAR *pcbConnStrOut)
  592. {
  593.   DBUG_ENTER("SQLBrowseConnect");
  594.   DBUG_RETURN(set_error((DBC FAR*) hdbc,"IM001","This doesn't work yet",4000));
  595. }
  598. RETCODE SQL_API SQLDisconnect(HDBC hdbc)
  599. {
  600.   LIST *list_element,*next_element;
  601.   DBC FAR *dbc=(DBC FAR*) hdbc;
  603.   for (list_element=dbc->statements ; list_element ;
  604.        list_element=next_element)
  605.   {
  606.     next_element=list_element->next;
  607.     SQLFreeStmt((STMT FAR*) list_element->data,SQL_DROP);
  608.   }
  609.   mysql_close(&dbc->mysql);
  610.   return SQL_SUCCESS;
  611. }