我将一个包含汉字的文件的数据用C insert到MySQL后乱码了,求助

balabalacha

文件的部分内容如下:

1. 
   
2. 283     第二分区        020179  水流指示        二层西前区
   
3. 284     第二分区        020180  信号碟阀        二层西前区
   
4. 285     第二分区        020181  防火阀  二层西前区
   
5. 286     第二分区        020182  防火阀  二层西前区
   

复制代码

1. 
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. #include <string.h>
   
5. #include <errno.h>
   
6. //#include <sys/iconv.h>
   
7. //#include "/usr/src/sys/sys/iconv.h"
   
8. //#include "/usr/src/bin/csh/iconv.h"
   
9. #include "/usr/local/include/mysql/mysql.h"
   
10. 
    
11. int
    
12. main(int argc,char **argv)
    
13. {
    
14.     MYSQL           mysql;
    
15.     FILE            *fp;
    
16. 
    
17.     if( 2 != argc ){
    
18.         fprintf(stderr,"Usage:./prog inputfile\n");
    
19.         exit(-1);
    
20.     }
    
21. 
    
22.     if( NULL == (fp=fopen(argv[1],"r")) ){
    
23.         fprintf(stderr,"%s\n",strerror(errno));
    
24.         exit(-1);
    
25.     }
    
26.     fprintf(stdout,"file %s opend...\n",argv[1]);
    
27. 
    
28.     mysql_init(&mysql);
    
29.     if(NULL==mysql_real_connect(&mysql,"localhost","zhongyi","localhost","ZhongYi",0,NULL,0)){
    
30.         fprintf(stderr,"Failed to connect to database: Error: %s\n",mysql_error(&mysql));
    
31.         exit(-1);
    
32.     }
    
33.     fprintf(stdout,"DataBase Connected...\n");
    
34.     if( 0 != mysql_options(&mysql,MYSQL_SET_CHARSET_NAME,"utf8")){
    
35.         fprintf(stderr,"mysql_options Error: %s\n",mysql_error(&mysql));
    
36.         exit(-1);
    
37.     }
    
38.     if( 0 != mysql_set_character_set(&mysql,"utf8") ){
    
39.         fprintf(stderr,"mysql_set_character_set Error: %s\n",mysql_error(&mysql));
    
40.         exit(-1);
    
41.     }
    
42. 
    
43.     /*  --------------------------------- */
    
44.     /*  021     第一分区    010021  光电感烟    一层东后区 */
    
45.     for(char buf[4096]; NULL != fgets(buf,4096,fp); ){
    
46.         /*
    
47.          * | fenqu  | char(30)
    
48.          * | bianma | int(6) unsigned zerofill
    
49.          * | liexin | char(30)
    
50.          * | weizhi | char(30)
    
51.          */
    
52.         char query[1024]="INSERT INTO zy(fenqu,bianma,liexin,weizhi) VALUES('";
    
53.         char *iter_b,*iter_e;
    
54. 
    
55.         for(iter_b=buf; 0 < *iter_b; ++iter_b);
    
56.         for(iter_e=iter_b; 0 > *iter_e; iter_e+=2);
    
57.         strncat(query,iter_b,iter_e-iter_b);
    
58.         strcat(query,"',");
    
59.         for(iter_b=iter_e; ' '==*iter_b; ++iter_b);
    
60.         for(iter_e=iter_b; ' '!=*iter_e; ++iter_e);
    
61.         strncat(query,iter_b,iter_e-iter_b);
    
62.         strcat(query,",'");
    
63.         for(iter_b=iter_e; 0 < *iter_b; ++iter_b);
    
64.         for(iter_e=iter_b; 0 > *iter_e; iter_e+=2);
    
65.         strncat(query,iter_b,iter_e-iter_b);
    
66.         strcat(query,"','");
    
67.         for(iter_b=iter_e; 0 < *iter_b; ++iter_b);
    
68.         for(iter_e=iter_b; 0 > *iter_e; iter_e+=2);
    
69.         strncat(query,iter_b,iter_e-iter_b);
    
70.         strcat(query,"')");
    
71. 
    
72.         /*  iconv */
    
73.         /*
    
74.         iconv_t   cd;
    
75.         char outbuf[1024];
    
76.         size_t in=strlen(query),out=1024;
    
77. 
    
78.         if( (iconv_t)-1 == (cd = iconv_open("UTF-8","GBK")) ){
    
79.             fprintf(stderr,"Iconv_open Error: %s\n",strerror(errno));
    
80.             exit(-1);
    
81.         }
    
82.         if( (size_t)-1 == iconv(cd,(char **)&query,(size_t *)&in,(char **)&outbuf,(size_t *)&out) ){
    
83.             fprintf(stderr,"Iconv Eoor: %s\n",strerror(errno));
    
84.             exit(-1);
    
85.         }
    
86.         */
    
87. 
    
88.         if( mysql_real_query(&mysql,query,strlen(query)) ){
    
89.             fprintf(stderr,"Error making query: %s\n",mysql_error(&mysql));
    
90.         }
    
91. 
    
92.         /*
    
93.         if( -1 == iconv_close(cd) ){
    
94.             fprintf(stderr,"Iconv_close Error: %s\n",strerror(errno));
    
95.             exit(-1);
    
96.         }
    
97.         */
    
98.     }
    
99. 
    
100.     fclose(fp);
     
101.     mysql_close(&mysql);
     
102. 
     
103.     exit(0);
     
104. }
     

复制代码

gcc -std=c99 -L /usr/local/lib/mysql/ -lmysqlclient -I /usr/local/include/mysql/ main.c -o sql

./sql ~/doc 运行后
进mysql看select * from zy;出来的是问号和空值

yejr

http://imysql.cn/?q=node/20,先看看吧

balabalacha

我将输入文件的编码用iconv改成了utf8

mysql:
------------------------------------------------------------------
mysql> create table zy ( xuhao int(6) unsigned zerofill auto_increment
primary key not null, fenqu char(50) character set utf8, bianma int(6)
unsigned zerofill, liexin char(50) character set utf8, weizhi char(50)
character set utf8 );
Query OK, 0 rows affected (0.62 sec)

mysql> describe zy;
+--------+--------------------------+------+-----+---------+----------------+
| Field  | Type                     | Null | Key | Default | Extra
    |
+--------+--------------------------+------+-----+---------+----------------+
| xuhao  | int(6) unsigned zerofill | NO   | PRI | NULL    |
auto_increment |
| fenqu  | char(50)                 | YES  |     | NULL    |
    |
| bianma | int(6) unsigned zerofill | YES  |     | NULL    |
    |
| liexin | char(50)                 | YES  |     | NULL    |
    |
| weizhi | char(50)                 | YES  |     | NULL    |
    |
+--------+--------------------------+------+-----+---------+----------------+
5 rows in set (0.28 sec)
------------------------------------------------------------------

然后程序main.c

1. 
   
2.      if( 0 != mysql_options(&mysql,MYSQL_SET_CHARSET_NAME,"utf8")){
   
3.         fprintf(stderr,"mysql_options Error:
   
4. %s\n",mysql_error(&mysql));
   
5.     }
   
6.     if( 0 != mysql_set_character_set(&mysql,"utf8") ){
   
7.         fprintf(stderr,"mysql_set_character_set Error:
   
8. %s\n",mysql_error(&mysql));
   
9.     }
   
10. 
    
11.     /*  --------------------------------- */
    
12.     /*  021     第一分区    010021  光电感烟    一层东后区
    
13. */
    
14.     for(char buf[4096]; NULL != fgets(buf,4096,fp); ){
    
15.         /*
    
16.          * | fenqu  | char(30)
    
17.          * | bianma | int(6) unsigned zerofill
    
18.          * | liexin | char(30)
    
19.          * | weizhi | char(30)
    
20.          */
    
21.         char query[1024]="INSERT INTO zy(fenqu,bianma,liexin,weizhi)
    
22. VALUES('";
    
23.         char *iter_b,*iter_e;
    
24. 
    
25.         for(iter_b=buf; 0 < *iter_b; ++iter_b);
    
26.         for(iter_e=iter_b; 0 > *iter_e; iter_e+=2);
    
27.         strncat(query,iter_b,iter_e-iter_b);
    
28.         strcat(query,"',");
    
29.         for(iter_b=iter_e; ' '==*iter_b; ++iter_b);
    
30.         for(iter_e=iter_b; ' '!=*iter_e; ++iter_e);
    
31.         strncat(query,iter_b,iter_e-iter_b);
    
32.         strcat(query,",'");
    
33.         for(iter_b=iter_e; 0 < *iter_b; ++iter_b);
    
34.         for(iter_e=iter_b; 0 > *iter_e; iter_e+=2);
    
35.         strncat(query,iter_b,iter_e-iter_b);
    
36.         strcat(query,"','");
    
37.         for(iter_b=iter_e; 0 < *iter_b; ++iter_b);
    
38.         for(iter_e=iter_b; 0 > *iter_e; iter_e+=2);
    
39.         strncat(query,iter_b,iter_e-iter_b);
    
40.         strcat(query,"')");
    
41. 
    
42.         /*  iconv */
    
43.         /*
    
44.         iconv_t   cd;
    
45.         char outbuf[1024];
    
46.         size_t in=strlen(query),out=1024;
    
47. 
    
48.         if( (iconv_t)-1 == (cd = iconv_open("UTF-8","GBK")) ){
    
49.             fprintf(stderr,"Iconv_open Error: %s\n",strerror(errno));
    
50.             exit(-1);
    
51.         }
    
52.         if( (size_t)-1 == iconv(cd,(char **)&query,(size_t *)&in,(char
    
53. **)&outbuf,(size_t *)&out) ){
    
54.             fprintf(stderr,"Iconv Eoor: %s\n",strerror(errno));
    
55.             exit(-1);
    
56.         }
    
57.         */
    
58. 
    
59.         if( mysql_real_query(&mysql,query,strlen(query)) ){
    
60.             fprintf(stderr,"Error making query:
    
61. %s\n",mysql_error(&mysql));
    
62.         }
    
63. 
    
64.         /*
    
65.         if( -1 == iconv_close(cd) ){
    
66.             fprintf(stderr,"Iconv_close Error: %s\n",strerror(errno));
    
67.             exit(-1);
    
68.         }
    
69.         */
    
70.     }
    
71. 
    
72.     fclose(fp);
    
73.     mysql_close(&mysql);
    
74. 
    
75.     exit(0);
    
76. 
    
77. }

复制代码

就可以了

yejr

恭喜啊

Namelessxp

俺通过Google把俺的BC++需要的文件都找齐了，呵呵，备用

balabalacha

原帖由 yejr 于 2006-12-17 20:09 发表
恭喜啊

可我还是不明白,头疼的是我不知道自己到底是具体的哪方面不明白

好像是编码