지돌스타 - 쿠키랩 블로그

1. Binary 타입 데이터를 DB에 저장하는 것에 대해
바이너리(Binary) 타입의 데이터를 DB에 저장한다는 것은 가령, 이미지나 사운드와 같은 데이터를 DB에 저장한다는 의미로 해석하면 편하다.

Binary파일을 DB에 넣을때 어떤 형태로 넣을 수 있을까? 

한가지 예는 익히 잘 알고 있는 Base64로 치환해서 text형태로 넣는 방식을 생각해볼 수 있다. Base64는 ASCII코드로 화면에 출력할 수 있는 64개 문자(ABCD...89+/e등)을 이용해 Binary 데이터를 Text로 표현해준다. 하지만 이 방식의 단점은 데이타를 64진수로 표현한 문자열이기 때문에 용량이 필연적으로 커지고 또 encode/decode를 해야하는 부담이 존재한다. base 64에 대해서 알고 싶다면 다음 링크를 보자.

• Base 64 - Wikipedia 
• 이미지 파일을 Base64로 인코딩하기

• ByteArray를 String으로 변환해보자.

• ByteArray를 문자열로 만들기

• Eclipse Galileo에서 C,C++ 개발환경 구축하기 - CDT, MinGW 
• Eclipse, MinGW, CDT 환경에서 C/C++과 MySQL 연동
  

mysql> describe images;
+-------+------------+------+-----+---------+-------+
| Field | Type       | Null | Key | Default | Extra |
+-------+------------+------+-----+---------+-------+
| id    | int(11)    | NO   | PRI |         |       |
| data  | mediumblob | YES  |     | NULL    |       |
+-------+------------+------+-----+---------+-------+
2 rows in set (0.00 sec)

CREATE TABLE `images` (
  `id` int(11) NOT NULL auto_increment,
  `data` mediumblob,
  PRIMARY KEY  (`id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8

#define SOCKET int

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <mysql/mysql.h>

#define DB_HOST "localhost or ip or domain"
#define DB_USER "DB 접속 ID"
#define DB_PASS "DB 접속 password"
#define DB_NAME "데이타베이스 이름"

int main(void) {
	MYSQL *connection, conn;
	FILE *fp;
	unsigned long len, file_size;
	int query_stat;
	char *buf , *buf_to, *query, *stat = "INSERT INTO images(data) VALUES('%s')";

	//DB 초기화 및 접속
	mysql_init(&conn);
	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 EXIT_FAILURE;
	} else {
		printf("Mysql connected\n");
	}

	//이미지를 불러오기
	fp = fopen("d:/image.png", "rb");
	if(fp==NULL) {
		fprintf(stderr, "image open error");
		mysql_close(connection);
		return EXIT_FAILURE;
	}
	rewind(fp);
	fseek(fp,0,SEEK_END);
	file_size = ftell(fp); //파일의 사이즈를 찾음
	fseek(fp,0,SEEK_SET);
	buf = (char*)malloc(file_size);
	fread(buf, sizeof(char), file_size, fp); //파일을 읽어와 buf에 참고
	fclose(fp);

	//이미지내 escape string 적용
	buf_to = (char*)malloc(file_size*2+1);
	mysql_real_escape_string(connection, buf_to, buf, file_size); 

	//Query 문 작성
	query = (char*)malloc(strlen(stat)+file_size*2+1);
	len = snprintf(query, strlen(stat)+file_size*2+1, stat, buf_to); 

	//Query 문 실행
	query_stat = mysql_real_query(connection, query, len); 
	if(query_stat != 0) {
		fprintf(stderr, "Mysql query error : %s\n", mysql_error(&conn));
	}

	//할당한 메모리 반환
	free(buf);
	free(buf_to);
	free(query);

	//DB 커넥션 닫기
	mysql_close(connection);
	return EXIT_SUCCESS;
}

• mysql_real_escape_string() 함수

• 안전한 null-terminated 문자열 복사

• mysql_real_query() 함수

#define SOCKET int

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <mysql/mysql.h>

#define DB_HOST "localhost or ip or domain"
#define DB_USER "DB 접속 ID"
#define DB_PASS "DB 접속 password"
#define DB_NAME "데이타베이스 이름"

int main(void) {
	MYSQL *connection, conn;
	MYSQL_RES *result;
	MYSQL_ROW row;
	FILE *fp;
	int query_stat;
	unsigned long *lengths;

	//DB 초기화 및 접속
	mysql_init(&conn);
	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 EXIT_FAILURE;
	} else {
		printf("Mysql connected\n");
	}

	//Query문 수행
	query_stat = mysql_query(connection,"SELECT data FROM images WHERE id=1");
	if(query_stat != 0) {
		fprintf(stderr, "Mysql query error : %s\n", mysql_error(&conn));
		return EXIT_FAILURE;
	}

	//Query문 수행한 결과를 통해 데이터 참조
	result = mysql_store_result(connection);
	if(result == NULL) {
		fprintf(stderr, "result is null\n");
		return EXIT_FAILURE;
	}
	row = mysql_fetch_row(result);
	lengths = mysql_fetch_lengths(result);
	mysql_free_result(result);
	printf("file lengths : %ld\n", lengths[0]);

	//이미지 저장
	fp = fopen("d:/savedImage.png", "wb");
	if(fp==NULL) {
		fprintf(stderr, "image save error");
		mysql_close(connection);
		return EXIT_FAILURE;
	}
	fwrite(row[0], lengths[0], 1, fp);
	fclose(fp);

	//DB 커넥션 닫기
	mysql_close(connection);
	return EXIT_SUCCESS;
}

#include <stdio.h>
#include <stdlib.h>

//#pragma pack(1) //struct member alignment를 1로 설정, 기본 설정이 8이라면 이것으로 20->19로 줄인다.
typedef struct st_person {
	unsigned __int16 user_id; //id, 2bytes 정수
	char user_name[15]; //이름, 15bytes 캐릭터형
	unsigned __int16 age; //나이, 2bytes 정수형

}PERSON;
//#pragma pack() //struct member alignment 원상복구

int main(void) {
	printf("struct PERSON size : %d\n",sizeof(PERSON));
	return EXIT_SUCCESS;
}

• struct member alignment에 대해

CREATE TABLE `persons` (
  `AREA` int(11) NOT NULL auto_increment,
  `COUNT` smallint(5) unsigned default NULL,
  `DATA` blob NOT NULL,
  PRIMARY KEY  (`AREA`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8

#define SOCKET int

#include <stdio.h>
#include <stdlib.h>
#include <memory.h>
#include <string.h>
#include <mysql/mysql.h>

#define DB_HOST "localhost or ip or domain"
#define DB_USER "DB 접속 ID"
#define DB_PASS "DB 접속 password"
#define DB_NAME "데이타베이스 이름"

#define TABLE_NAME "persons"
#define SQL_DROP_TABLE "DROP TABLE IF EXISTS %s"
#define SQL_CREATE_TABLE "CREATE TABLE `%s` (\
`AREA` int NOT NULL AUTO_INCREMENT,\
`COUNT` smallint unsigned,\
`DATA` BLOB NOT NULL,\
PRIMARY KEY(`AREA`)\
) ENGINE=MyISAM DEFAULT CHARSET=utf8"
#define SQL_INSERT_DATA "INSERT INTO %s(DATA,COUNT) values('%s',%d)"
#define SQL_SELECT_DATA "SELECT `DATA`, `COUNT` FROM %s WHERE `AREA`=%d"

#pragma pack(1) //struct member alignment를 1로 설정, 기본 설정이 8이라면 이것으로 20->19로 줄인다.
typedef struct st_person {
	unsigned __int16 user_id; //id, 2bytes 정수
	char user_name[15]; //이름, 15bytes 캐릭터형
	unsigned __int16 age; //나이, 2bytes 정수형

}PERSON;
#pragma pack() //struct member alignment 원상복구

int connect();
int close();
int create_table();
int drop_table();
PERSON* add_data(PERSON *person_list, int index, unsigned __int16 user_id, unsigned __int16 age, char* user_name);
int remove_all_data(PERSON* person_list);
int insert_data(PERSON* person_list, int count);
int select_data(int area);

MYSQL *connection, conn;

int main(void) {
	printf("PERSON struct size : %d\n",sizeof(PERSON));
	connect();
	drop_table();
	create_table();

	PERSON *person_list;
	person_list = add_data(NULL,0,1,30,"jidolstar");
	person_list = add_data(person_list,1,2,22,"joykim");
	person_list = add_data(person_list,2,3,2,"tae hyun");
	insert_data(person_list,3);
	free(person_list);
	select_data(1);

	person_list = add_data(NULL,0,4,30,"addlayer");
	person_list = add_data(person_list,1,5,22,"eye");
	person_list = add_data(person_list,2,6,2,"unclejoe");
	person_list = add_data(person_list,3,7,3,"miracle");
	insert_data(person_list,4);
	free(person_list);
	select_data(2);


	close();
	return EXIT_SUCCESS;
}

/**
 * DB 접속
 */
int connect() {
	// mysql 초기화
	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));
		exit(0);
	} else {
		printf("Mysql connected\n");
	}
	return 0;
}
/**
 * 데이타 베이스 닫음
 */
int close() {
	mysql_close(connection);
	printf("mysql closed\n");
	return 1;
}

/**
 * 테이블 생성
 */
int create_table() {
	int query_stat;
	char buff[1024];

	memset(buff,0x00,sizeof(buff));
	sprintf( buff, SQL_CREATE_TABLE, TABLE_NAME );
	query_stat = mysql_query(connection,buff);
	if( query_stat != 0 ) {
		fprintf(stderr, "Mysql query error : %s\n", mysql_error(&conn));
		exit(0);
	} else {
		printf("created table\n");
	}
	return 0;
}

/**
 * 기존 테이블 삭제
 */
int drop_table() {
	int query_stat;
	char buff[1024];

	//기존 테이블 삭제
	memset(buff,0x00,sizeof(buff));
	sprintf( buff, SQL_DROP_TABLE, TABLE_NAME );
	query_stat = mysql_query(connection,buff);
	if( query_stat != 0 ) {
		fprintf(stderr, "Mysql query error : %s\n", mysql_error(&conn));
		exit(0);
	} else {
		printf("table dropped\n");
	}
	return 0;
}

/**
 * 데이터 추가
 */
PERSON* add_data(PERSON *person_list, int index, unsigned __int16 user_id, unsigned __int16 age, char* user_name) {
	PERSON *current;
	if(person_list == NULL ) {
		person_list = (PERSON*)malloc(sizeof(PERSON));
		current = person_list;
	} else {
		person_list = (PERSON*)realloc(person_list, sizeof(PERSON)*(index+1));
		current = person_list + index;
	}
	current->user_id = user_id;
	current->age = age;
	memset(current->user_name,0x00,sizeof(current->user_name));
	strcpy(current->user_name,user_name);
	//printf("added user_id:%d, age:%d, name:%s\n",current->user_id,current->age,current->user_name);
	return person_list;
}

/**
 * 모든 데이터 삭제
 */
int remove_all_data(PERSON* person_list) {
	free(person_list);
	return 0;
}

/**
 * 데이타를 디비 테이블에 삽입
 */
int insert_data(PERSON* person_list, int count) {
	int query_stat;
	unsigned long len, size;
	char *buf_to, *query;

	size = sizeof(PERSON)*count*2+1;
	buf_to = (char*)malloc(size);
	mysql_real_escape_string(connection, buf_to, (char*)person_list, sizeof(PERSON)*count);

	//Query 문 작성
	query = (char*)malloc(sizeof(SQL_INSERT_DATA)+size);
	len = snprintf(query, sizeof(SQL_INSERT_DATA)+size, SQL_INSERT_DATA, TABLE_NAME, (char*)buf_to, count );

	//Query 문 실행
	query_stat = mysql_real_query(connection, query, len);
	if(query_stat != 0) {
		fprintf(stderr, "Mysql query error : %s\n", mysql_error(&conn));
	} else {
		printf("insert complete\n");
	}

	//할당한 메모리 반환
	free(buf_to);
	free(query);
	return 0;
}

/**
 * 데이타를 디비에서 읽어옴
 */
int select_data(int area) {
	char query[1024];
	int query_stat;
	int count=0;
	int i;
	PERSON *person_list, *person;
	MYSQL_RES *result;
	MYSQL_ROW row;

	memset(query,0x00,sizeof(query));
	sprintf(query, SQL_SELECT_DATA, TABLE_NAME, area);
	query_stat = mysql_query(connection,query);
	if(query_stat != 0) {
		fprintf(stderr, "Mysql query error : %s\n", mysql_error(&conn));
		exit(0);
	}

	//갯수만큼 화면에 데이터 출력
	result=mysql_store_result(connection);
	row = mysql_fetch_row(result);
	mysql_free_result(result);
	count = atoi(row[1]); //갯수
	person_list = (PERSON*)row[0]; //한개의  데이터
	for( i=0; i<count; i++ ) {
		person = person_list + i;
		printf("user_id:%d, age:%d, name:%s\n",person->user_id,person->age,person->user_name);
	}
	free(person_list);
	return 0;
}

package com.jidolstar.person.domain;

public class PersonArea {
	private int area;
	private int count;
	private byte[] data;
	
	public int getArea() {
		return area;
	}
	public void setArea(int area) {
		this.area = area;
	}
	public int getCount() {
		return count;
	}
	public void setCount(int count) {
		this.count = count;
	}
	public byte[] getData() {
		return data;
	}
	public void setData(byte[] data) {
		this.data = data;
	}
}

package {
	import flash.utils.ByteArray;

	[RemoteClass(alias="com.jidolstar.person.domain.PersonArea")]
	public class PersonArea	{
		public var area:int;
		public var count:int;
		public var data:ByteArray;
	}
}

package {
	public class AreaDetail {
		public var area:int;
		public var id:int;
		public var name:String;
		public var age:int;
	}
}

<?xml version="1.0" encoding="utf-8"?>
<s:Application xmlns:fx="http://ns.adobe.com/mxml/2009" 
			   xmlns:s="library://ns.adobe.com/flex/spark" 
			   xmlns:mx="library://ns.adobe.com/flex/mx" minWidth="955" minHeight="600" 
			   xmlns:halo="library://ns.adobe.com/flex/halo">
	<fx:Declarations>
		<s:RemoteObject id="ro" destination="personRO">
			<s:method name="getPersonArea" result="result_handler(event)" fault="mx.controls.Alert.show(event.fault.faultString)"/> 
		</s:RemoteObject>
		<s:ArrayCollection id="ac"/>
	</fx:Declarations>
	<fx:Script>
		<![CDATA[
			import mx.collections.ArrayCollection;
			import mx.controls.Alert;
			import mx.rpc.events.ResultEvent;
			
			private function result_handler($event:ResultEvent):void {
				var personArea:PersonArea = $event.result as PersonArea;
				var count:int = personArea.count;
				var person:PersonDetail;
				var data:ByteArray = personArea.data;
				var area:int = personArea.area;
				ac.removeAll();
				data.endian = Endian.LITTLE_ENDIAN; //구조체로 저장된 데이터가 little endian인 경우 이 설정을 해야한다.//http://blog.naver.com/kimsumin75/20055881438
				ac.disableAutoUpdate();
				while( count-- ) {
					person = new PersonDetail;
					person.area = area;
					person.id = data.readShort()
					person.name = data.readUTFBytes(15,"utf-8");
					person.age = data.readShort();
					//trace(data.readByte()); //만약 c에서 #progma pack(1)을 사용하지 않았다면 19가 아닌 20바이트가 넘어올 것이므로 1바이트가 비게 된다. 이때는 이 부분의 주석이 풀어져야 제대로 읽어올 수 있다.
					ac.addItem(person);
				}
				ac.enableAutoUpdate();
				ac.refresh();
			}

			protected function button1_clickHandler(event:MouseEvent):void
			{
				ro.getPersonArea(parseInt(tiArea.text));
			}

		]]>
	</fx:Script>
	<halo:Form x="10" y="7" width="225" height="132">
		<halo:FormItem label="area">
			<s:TextInput id="tiArea" text="1"/>
		</halo:FormItem>
		<s:Button label="불러오기" click="button1_clickHandler(event)"/>
	</halo:Form>
	<halo:DataGrid x="243" y="10" height="360" width="385" dataProvider="{ac}">
		<halo:columns>
			<halo:DataGridColumn headerText="AREA" dataField="area"/>
			<halo:DataGridColumn headerText="ID" dataField="id"/>
			<halo:DataGridColumn headerText="NAME" dataField="name"/>
			<halo:DataGridColumn headerText="AGE" dataField="age"/>
		</halo:columns>
	</halo:DataGrid>
</s:Application>

#define SOCKET int

#include <stdio.h>
#include <mysql/mysql.h>

#define DB_HOST "localhost 또는 아이피, 도메인"
#define DB_USER "DB 사용자 ID"
#define DB_PASS "DB 사용자 Password"
#define DB_NAME "DB 이름"

int main() {
	MYSQL *conn_ptr;
	conn_ptr = mysql_init(NULL);
	if(!conn_ptr) {
		printf("mysql_init failed!!\n");
		return 0;
	}

	conn_ptr = mysql_real_connect(conn_ptr, DB_HOST, DB_USER, DB_PASS, DB_NAME, 3306,(char *)NULL, 0);

	if(conn_ptr) {
		printf("연결이 성공 되었습니다.\n");
	} else {
		printf("연결에 실패했습니다.\n");
	}
	mysql_close(conn_ptr);
	return 1;
}

코드를 만들었으니 이제 MySQL 라이브러리를 사용한다는 컴파일 옵션을 주어야 한다. 방법은 다음과 같이 하면 되겠다.

이클립스 메뉴에서 Project > Properties로 들어간다. C/C++Build > Setting으로 들어가 Tool Setting 탭으로 누른다. 다음으로 MinGW C Linker > Libraries를 선택한다. 아래처럼 mysql을 등록한다. 이렇게 하면 컴파일시 -lmysql로 옵션을 주는 것과 같아진다.

Ctrl+F11이나 Run > Run 을 해보자. 콘솔창에 아래처럼 나오면 성공한 것이다.

1. libmysql.dll을 C:/windows/System32에 복사한다.
2. 프로젝트의 Debug폴더나 Release폴더(즉, exe 실행파일과 같은 경로)에 libmysql.dll을 복사한다.
   
   

dll과 함께 컴파일 처리하면 좋겠는데 아직 방법은 모르겠다.

libmysql.dll을 얻는 방법은 http://www.dll-files.com/ 에 접속해 libmysql.dll을 찾는다. libmysql.dll을 다운로드 받을 수 있는 페이지가 나오면 다른거 누르지 말고 아래 그림과 같은 Free download의 Download 버튼을 눌러 다운로드 받는다.

#define SOCKET int

#include <stdio.h>
#include <mysql/mysql.h>

#define DB_HOST "localhost 또는 아이피, 도메인"
#define DB_USER "DB 사용자 ID"
#define DB_PASS "DB 사용자 Password"
#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 \
    ) TYPE = MYISAM ;"
#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 query error : %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 error : %s", mysql_error(&conn));
			return 1;
		}
	}

	// 셀렉트
	query_stat=mysql_query(connection,SQL_SELECT_RECORD);
	if (query_stat != 0) {
		fprintf(stderr, "Mysql query error : %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 error : %s", mysql_error(&conn));
		return 1;
	}

	// DB 연결 닫기
	mysql_close(connection);
	return 0;
}

글쓴이 : 지돌스타(http://blog.jidolstar.com/679)