MySQL MFC 연동 예제

[1] (win32 console project 생성)

 

#include <stdio.h>

#include <winsock2.h>

#include <mysql.h>

 

#pragma comment(lib, "libmySQL.lib")

 

int main(int argc, char* argv[])

{

     MYSQL mysql;

     mysql_init(&mysql);

     if(!mysql_real_connect(&mysql, NULL, "아이디", "비번", NULL, 3306, NULL, 0))

     {

        printf("아이디나 비밀번호가 틀리다. \n");

        exit(1);

     }

     printf("성공적으로 연결되었습니다. \n");

     mysql_close(&mysql);

 

return 0;

}

 

 

 

[2]

#include "stdafx.h"

#define SOCKET int

#include <string.h>

#include <stdio.h>

#include <mysql.h>

 

#pragma comment(lib, "libmysql.lib")

#pragma comment(lib, "ws2_32.lib")

 

#define DB_HOST "호스트 IP, 도메인 또는 localhost"

#define DB_USER "접속 ID"

#define DB_PASS "접속 암호"

#define DB_NAME "DB명"

 

#define SQL_CREATE_TABLE " CREATE TABLE 'mysql_api_test' (\

  'id' INT NOT NULL AUTO_INCREMENT PRIMARY KEY, \

  'num' INT NULL, \

  'string' VARCHAR( 20 ) NULL \

);"

#define SQL_INSERT_RECORD " INSERT INTO 'mysql_api_test' ( 'id', 'num' 'string') \

VALUES ( NULL, '%d', '%s' );"

#define SQL_SELECT_RECORD "SELECT * FROM 'mysql_api_test'"

#define SQL_DROP_TABLE " DROP TABLE 'mysql_api_test'"

 

int main()

{

     MYSQL *connection=NULL, conn;

     MYSQL_RES * sql_result;

     MYSQL_ROW sql_row;

     int query_stat;

     int i;

 

     char query[255];

     mysql_init(&conn); // 초기화

     // DB 연결

     connection = mysql_real_connect(&conn, DB_HOST, DB_USER, DB_PASS, DB_NAME, 3306, (char *)NULL, 0);

     if(connection==NULL)

     {

          fprintf(stderr, "Mysql connection error : %s", mysql_error(&conn));

           return 1;

     }

     // 테이블 생성

query_stat=mysql_query(connection, SQL_CREATE_TABLE);

if ( query_Stat != 0)

{

     fprintf(stderr, "Mysql quey error1 : %s", mysql_error(&conn));

     return 1;

}

 

// 레코드 삽입

for(i=0; i<5; i++)

{

sprintf(query, SQL_INSERT_RECORD, 100+i, "안녕하세요");

     query_stat = mysql_query(connection, query);

     if (query_Stat != 0)

     {

          fprintf(stderr, "Mysql query error2 : %s", mysql_error(&conn));

          return 1;

     }

}

 

//셀렉트

query_stat = mysql_query(connection, SQL_SELECT_RECORD);

if ( query_stat != 0)

{

     fprintf(stderr, "Mysql query error3 : %s", mysql_error(&conn));

     return 1;

}

 

// 결과 출력

sql_result=mysql_store_result(connection);

while((sql_row=mysql_fetch_row(sql_result))!=NULL)

{

   printf("%2s %2s %s\n", sql_row[0], sql_row[1], sql_row[2]);

}

mysql_free_result(sql_result);

 

// 테이블 삭제

query_stat=mysql_query(connection, SQL_DROP_TABLE);

if ( query_stat != 0)

{

     fprintf(stderr, "Mysql query error4 : %s", mysql_error(&conn));

     return 1;

}

 

// DB 연결 닫기

mysql_close(connection);

return 0;

}