select_test.c

《嵌入式Linux应用开发详解》中的源代码

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <time.h>
#include <libmsql/msql.h>

#define VERBOSE

#define SELECT_QUERY "select * from xutable"


int main(argc,argv)
	int	argc;
	char	*argv[];
{
	int	sock,
		numrow,
		num;
	char	qbuf[160],
		*host,
		*db,
		*qty;
	m_result *res;
	m_row row;
	
	//if (argc != 3 && argc != 5)
	//{
	//	printf("usage : select_test [-h host] <dbname> <num>\n\n");
	//	exit(1);
	//}
        if (argc == 5)
        {
                host = argv[2];
                db = argv[3];
                qty = argv[4];
        }
        else
        {
                host = NULL;
                db = argv[1];
                qty = argv[2];
        }

	if ((sock = msqlConnect(host)) < 0)
	{
		printf("Couldn't connect to engine!\n%s\n\n", msqlErrMsg);
		perror("");
		exit(1);
	}
	printf("connect to engine!\n");

	if (msqlSelectDB(sock,db) < 0)
	{
		printf("Couldn't select database %s!\n%s\n",argv[1],msqlErrMsg);
	}
	printf("select db!\n");


	//while (count < num)
	//{
		//snprintf(qbuf,sizeof(qbuf),SELECT_QUERY,count);
	sprintf(qbuf,SELECT_QUERY);
	if(numrow=msqlQuery(sock,qbuf) < 0)
	{
		printf("Query failed (%s)\n",msqlErrMsg);
		//printf("Selected %d rows\n",count);
		exit(1);
	}
	printf("query good!\n");
	res=msqlStoreResult();
	printf("get result!\n");
	printf("%d \n",numrow);
	numrow=msqlNumRows(res);
	for(num=0;num<numrow;num++)
	{
		msqlDataSeek(res,num);
		row=msqlFetchRow(res);
		//printf("fetch row!\n");
		printf("%s,%d \n",row[0],row[1]);
	}

	//}
	msqlClose(sock);
	exit(0);
}