任務：將近10天的溫度資料，9個溫度測點，取樣間隔為1分鐘，共計12萬行資料，需要匯出每小時的溫度資料。

0. 資料格式和資料庫設計

資料格式如下：有3列，分別是日期，時間，溫度。檔名是測點編號。

資料庫設計為如下：

create database sensorDB;
use sensorDB;
create table sensor
(
	ID smallint ,
    dt Date,
    tm Time,
    temp float,
    primary key (ID,dt,tm)
);

create view temperature
as
select ID, cast(CONCAT(dt,' ',tm) as datetime) '時間' , temp from sensor   ;
 
 

1.Txt格式檔案匯入資料庫

用C語言寫了一個小工具，可以把txt轉成sql語句【見後面的原始碼】

執行後，輸入txt的檔名，要插入的表名，和感測器的編號即可。

程式執行完畢之後，自動生成sql語句如下：

然後直接執行sql語句，資料就匯入到資料庫中了。

2.按指定間隔查詢資料

利用了timestampdiff（）來計算時間間隔 ，並利用%來逐個判斷

</pre><p></p></blockquote><blockquote style="margin:0 0 0 40px; border:none; padding:0px"><p><span style="font-size:24px"></span></p><pre code_snippet_id="531991" snippet_file_name="blog_20141125_4_1936774" name="code" class="sql">select * from temperature where ID = 9 and  timestampdiff(MINUTE,時間,'2014-04-19 15:00:00')%60 =0; 
 

如下便是間隔1小時的溫度資料

附件：txt轉sql原始碼 C

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

#define BUFFER_LEN 2048
const char sp[] = { ' ', '\t', ';','\r','\n' };

 
void error(char *msg)
{
	printf("ERROR:%s",msg);
	fflush(stdin);
	getchar();
	exit(1);
}
int isSeperator(char  ch)
{
	
	for (int i = 0; i < sizeof(sp) / sizeof(char); i++)
	{
		if ( ch == sp[i])
		{
			return 1;
		}
	}
	return 0;
}
int main()
{
	printf("=============================\n");
	printf("          txt2sql\n");
	printf("=============================\n");
	printf("data fielname: ");
	fflush(stdin);
	char filename_in[256], filename_out[256];
	scanf("%s",filename_in);
	strcpy(filename_out, filename_in);
	strcat(filename_out, "_sql.txt");
	strcat(filename_in, ".txt");
	printf("table name: ");
	fflush(stdin);
	char table_name[256];
	scanf("%s", table_name);

	printf("sensor ID: ");
	fflush(stdin);
	char sensor_ID[256];
	scanf("%s", sensor_ID);


	FILE *fin = fopen(filename_in, "r");
	FILE *fout = fopen(filename_out, "w");
	if (fin == NULL || fout == NULL)
	{
		error("cannot open file");
	}
	char buffer[BUFFER_LEN];
	while (fgets(buffer, BUFFER_LEN, fin) != 0)
	{
		//除去多餘的分隔符
        char elem[BUFFER_LEN];
		int k = 0;
		memset(elem, 0, sizeof(elem));

		for (int i = 0; i < strlen(buffer); i++)
		{
			if (buffer[i] == '\n' || buffer[i] == '\r' || buffer[i]=='\0') buffer[i] = ' ';
		}


		for (int i = 0; i < strlen(buffer); i++)
		{
			if (!isSeperator(buffer[i]))
			{
				elem[k++] = buffer[i];
			}
			else
			{
				//如果最後一個是分隔符則跳過
				if (i == strlen(buffer) && isSeperator(buffer[i]))
					continue;
				//如果下一個還是分隔符，則跳過。
				if (i != strlen(buffer) - 1 && isSeperator(buffer[i + 1]))
					continue;
				if (i != strlen(buffer) - 1 && !isSeperator(buffer[i + 1]))
								elem[k++] = buffer[i];
			}
		}
		/*printf("\"%s\"",elem);*/
		//經過處理的elem只有包含一個分隔符在一起的情況，最後沒有空元素

		fprintf(fout, "INSERT INTO %s VALUES ('%s',", table_name,sensor_ID);
		int left = 0;
		for (int i = 0; i < strlen(elem); i++)
		{
			if (isSeperator(elem[i]))
			{
				
				fprintf(fout, "\'");
				for (int j = left; j < i; j++)
				{
					fprintf(fout, "%c", elem[j]);
				}
			   	fprintf(fout, "\',");
				left = i + 1;
			}
		}
		//the last one
		fprintf(fout, "\'");
		for (int j = left; j < strlen(elem); j++)
		{
			fprintf(fout, "%c", elem[j]);
		}
		fprintf(fout, "\');\n");
		 
	}
	


	fclose(fin); 
	fclose(fout);

	printf("Done!");
	fflush(stdin);
	getchar();
	exit(0);
}