mysql导入数据一则

wp231957

其实很简单的，但是对于摸着石头过河的我来说  调试了好几个小时
AMTF，百度里全是大坑，咕咚就掉进去了
sql 语句执行错误 就报个错误号，根本就不告诉你哪里错了  什么原因错的，应该怎么改

好了，目标：将文本文件的数据 导入mysql数据表
终实现：

1. f = open('商务英语词汇 copy.txt',encoding = 'utf-8')
   
2. lst=[]
   
3. for field in f:
   
4.     try:
   
5.         ename=field.split("=")[0].strip()
   
6.         chname=field.split("=")[1].strip()
   
7.         lst.append((ename,chname))   #构建列表，元素为元组 才可以被sql解释器执行
   
8.     except Exception:  #因原始文本文件中  有些记录不符合要求，故舍去
   
9.         pass
   
10. f.close()     
    
11. import MySQLdb  as mysql   #这个比较奇怪，虽然导入的是MySQLdb  但pip  mysql 就可以了
    
12. db = mysql.connect("localhost", "root", "123456", "wpdata", charset='utf8' )
    
13. cursor = db.cursor()
    
14. sql = "INSERT INTO  worda(ename,chname) values(%s, %s)"
    
15. cursor.executemany(sql,lst)  #一次插入多条记录
    
16. db.commit()
    
17. cursor.close()
    
18. db.close()
    
19. print('OK')
    

复制代码

下期将公布NODE.js版，那个容易一些，因为曾经实现过，只不过换了电脑   需要重新写

wp231957

NODE+MYSQL 版  从文本文件导入数据表

这里面坑也不少，好几千条数据，只要有一条数据不符合要求，整个sql语句就不执行
，但是这极个别的数据，从几千条里筛选   肉眼还真办不到，好在终于实现

1. let fs = require('fs');   
   
2. let mysql = require('mysql');
   
3. 
   
4. let config = {  
   
5.     host     : 'localhost',  
   
6.     user     : 'root',  
   
7.     password : '123456',  
   
8.     database : 'wpdata'  
   
9.   };  
   
10. let pool = mysql.createPool(config);
    
11. 
    
12. //构造单词信息
    
13. var arr=new Array();
    
14. fs.readFile('./商务英语词汇 copy.txt', {flag: 'r+', encoding: 'utf8'}, function (err, data) {
    
15.     if(err) {
    
16.         console.error(err);
    
17.      return;
    
18.     }
    
19.     s=data.split("\n");
    
20.     s.forEach(function(cval, index, sarr){
    
21.         var tmp=cval.replace(/\r\n/gm,"").split("=",2);   //只分割第一个标识符 后面即使存在 也不分割
    
22.         if (tmp.length==2){     //原始文件中个别行不符合要求
    
23.             arr.push(tmp);   
    
24.         }
    
25.     });
    
26.     //把单词信息写入数据库（此处用的是批量插入记录）
    
27.     sql2="INSERT INTO wordb (ename,chname) VALUES ?";
    
28.     pool.getConnection((err, connection) => {
    
29.         if (err) {
    
30.             console.error(err);
    
31.         }
    
32.         else
    
33.         {
    
34.             connection.query(sql2,[arr],(err, rows)=>{  //arr.slice(126,128) 截取数组
    
35.                 if (err) {
    
36.                     console.error(err);
    
37.                 }
    
38.                 else
    
39.                 {
    
40.                     console.log("插入数据成功");
    
41.                     connection.release();
    
42.                     pool.end();
    
43.                 };
    
44.             });
    
45.         };
    
46.         
    
47.     });
    
48. });
    
49. 
    
50. 
    
51. 
    
52. 
    

复制代码