C語言連接mysql源代碼實例
不需要按照ODBC驅動。通過mysql自帶的3306端口進行數據傳輸。
注意libmysq.dll與對應服務器版本的關系。
// uplog.cpp : Defines the entry point for the console application. //include "stdafx.h"
include <stdio.h>
include <stdlib.h>
include <string.h>
include <mysql/mysql.h>
pragma comment(lib, "libmysql.lib")
struct DBINFO { char host[20]; char user[20]; char passwd[20]; char db[20]; };
struct LOGS{ char sn[20]; char mac[20]; char biosV[30]; char biosD[30]; char ec[10]; char touchFW[20]; char oaKey[35]; int batlvl; };
void help(void) { fprintf(stderr, "uplog <host> <user> <pwd> <logfile>"); exit(1); }
int uplog(DBINFO info, LOGS logs) { MYSQL *my = NULL; char sql[512];
printf("\nUpload test logs to DB server....\n");
my = mysql_init(NULL); if (my == NULL) { fprintf(stderr, "\n] Error: Unable to init APIs...\n"); return 1; }
if(mysql_real_connect(my, info->host, info->user, info->passwd, NULL, MYSQL_PORT, NULL, 0) == 0) { fprintf(stderr, "\n] Error: Unable to connect server...\n"); if(my!=NULL) mysql_close(my); return 1; }
if (mysql_select_db(my, info->db)<0) { fprintf(stderr, "\n] Error: Unable to select db(%s)...\n", info->db); if(my!=NULL) mysql_close(my); return 1; }
sprintf(sql, "INSERT INTO
testlogs
(Serial_number
,Mac_addr
,BIOS_version
,BIOS_date
,EC_version
,Touch_FW
,OA_KEY
,Battery_level
) VALUES (" "'%s', '%s', '%s', '%s', '%s', '%s', '%s', %d)",logs->sn, logs->mac, logs->biosV, logs->biosD, logs->ec, logs->touchFW, logs->oaKey, logs->batlvl);if(mysql_query(my, sql) != 0) { printf("\n] Error: Unable to execute query...\n"); if (my!=NULL) mysql_close(my); return 1; }
mysql_close(my);
printf("%s\n Upload to DB ok\n", sql);
return 0; }
int parseLogs(FILE f, LOGS log) { char buf[512]; char *father; int index = 0;
printf("parsing logs... "); fgets(buf, 512, f); if(strlen(buf) < 10) return 1;
/* parsing log format, like |KEY1#VALUE1|KEY2#VALUE2/ father = strtok(buf, "|#"); while(father != NULL) { if(strncmp("MACADDR", strupr(father), strlen(father))==0) { father = strtok(NULL, "|#"); if (father != NULL) { printf("1"); index++; strcpy(log->mac, father); } }
if(strncmp("SN", strupr(father), strlen(father))==0) { father = strtok(NULL, "|#"); if (father != NULL) {
printf("2"); index++; strcpy(log->sn, father); } }if(strncmp("BIOSD", strupr(father), strlen(father))==0) { father = strtok(NULL, "|#"); if (father != NULL) {
printf("3"); index++; strcpy(log->biosD, father); } }if(strncmp("BIOSV", strupr(father), strlen(father))==0) { father = strtok(NULL, "|#"); if (father != NULL) {
printf("4"); index++; strcpy(log->biosV, father); } }if(strncmp("EC", strupr(father), strlen(father))==0) { father = strtok(NULL, "|#"); if (father != NULL) {
printf("5"); index++; strcpy(log->ec, father); } }if(strncmp("OAKEY", strupr(father), strlen(father))==0) { father = strtok(NULL, "|#"); if (father != NULL) {
printf("6"); index++; strcpy(log->oaKey, father); } }if(strncmp("TOUCHFW", strupr(father), strlen(father))==0) { father = strtok(NULL, "|#"); if (father != NULL) {
printf("7"); index++; strcpy(log->touchFW, father); } }if(strncmp("BATTERY", strupr(father), strlen(father))==0) { father = strtok(NULL, "|#"); if (father != NULL) {
printf("8"); index++; log->batlvl = atoi(father); } }father = strtok(NULL, "|#"); }
printf("\n%s, %s, %s, %s, %s, %s, %s, %d\n", log->sn, log->mac, log->biosV, log->biosD, log->ec, log->touchFW, log->oaKey, log->batlvl);
printf("index=%d", index); if (index != 8) return 1; else return 0; }
int main(int argc, char argv[]) { FILE f; DBINFO dbinfo; LOGS log; memset(&dbinfo, '\0', sizeof(dbinfo)); memset(&log, '\0', sizeof(log));
if (argc != 5) help();
if ((f=fopen(argv[4], "r"))==NULL) { fprintf(stderr, "\n] Error open file!\n"); return 1; }
if(parseLogs(f, &log)) { fprintf(stderr, "\n] Error log file format!\n"); return 1; }
strncpy(dbinfo.host, argv[1], strlen(argv[1])); strncpy(dbinfo.user, argv[2], strlen(argv[2])); strncpy(dbinfo.passwd, argv[3], strlen(argv[3])); strncpy(dbinfo.db, "test", strlen("test"));
return uplog(&dbinfo, &log);
}</pre>