python2.7 MySQLdb insert

CREATE TABLE `a` (

  `id` int(15) NOT NULL AUTO_INCREMENT,

  `ip` varchar(20) NOT NULL,

  `apply` varchar(20) NOT NULL,

  PRIMARY KEY (`id`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

cat 1.txt

<code>tomcat  </code><code>192.1</code><code>.</code><code>1.121</code>

<code>redis </code><code>192.1</code><code>.</code><code>1.122</code>

<code>mongodb  </code><code>192.1</code><code>.</code><code>1.122</code>

<code>tomcat  </code><code>192.1</code><code>.</code><code>1.122</code>

<code>tomcat  </code><code>192.1</code><code>.</code><code>1.123</code>

<code>redis </code><code>192.1</code><code>.</code><code>1.124</code>

<code>mongodb  </code><code>192.1</code><code>.</code><code>1.124</code>

<code>tomcat  </code><code>192.1</code><code>.</code><code>1.124</code>

<code>other  </code><code>192.1</code><code>.</code><code>1.125</code>

<code>tomcat  </code><code>192.1</code><code>.</code><code>1.126</code>

<code>fastdfs </code><code>192.1</code><code>.</code><code>1.127</code>

<code>fastdfs </code><code>192.1</code><code>.</code><code>1.128</code>

<code>fastdfs </code><code>192.1</code><code>.</code><code>1.129</code>

<code>other   </code><code>192.1</code><code>.</code><code>1.130</code>

<code>other   </code><code>192.1</code><code>.</code><code>1.131</code>

<code>fastdfs </code><code>192.1</code><code>.</code><code>1.132</code>

<code>fastdfs </code><code>192.1</code><code>.</code><code>1.133</code>

<code>python </code><code>1.py</code>

<code>#!/usr/bin/env python</code>

<code># -*- coding: utf-8 -*-</code>

<code>import</code> <code>sys</code>

<code>#import pymysql</code>

<code>#pymysql.install_as_MySQLdb()</code>

<code>import</code> <code>MySQLdb as mdb</code>

<code>con </code><code>=</code> <code>mdb.connect(</code><code>'127.0.0.1'</code><code>, </code><code>'root'</code><code>, </code><code>'123456'</code><code>, </code><code>'db03'</code><code>)</code>

<code>def</code> <code>test(param):</code>

<code>    </code><code>with con:</code>

<code>        </code><code>cur </code><code>=</code> <code>con.cursor()</code>

<code>        </code><code># cur.execute("CREATE TABLE IF NOT EXISTS \</code>

<code>        </code><code>#             Writers(Id INT PRIMARY KEY AUTO_INCREMENT, Name VARCHAR(25))";"INSERT INTO Writers(Name) VALUES('Jack London')")</code>

<code>        </code><code># cur.execute("INSERT INTO Writers(Name) VALUES('Jack London'),INSERT INTO Writers(Name) VALUES('Honore de Balzac')")</code>

<code>        </code><code># sql = 'INSERT INTO Writers(Name) VALUES(%s)'</code>

<code>        </code><code># param = ('Jack London', 'Honore de Balzac')</code>

<code>        </code><code># cur.executemany(sql, param)</code>

<code>        </code><code># sql="insert a(ip,yy) values(['tomcat', '192.1.1.121']); insert a(ip,yy) values(['redis', '192.1.1.122']);"</code>

<code>        </code><code># cur.execute(sql)</code>

<code>        </code><code>sql </code><code>=</code> <code>'INSERT INTO a(apply,ip) VALUES(%s,%s)'</code>

<code>        </code><code>#param = [['tomcat', '192.1.1.121'], ['redis', '192.1.1.122'], ['mongodb', '192.1.1.122']]</code>

<code>        </code><code>#param = ((username1, salt1, pwd1), (username2, salt2, pwd2), (username3, salt3, pwd3))</code>

<code>        </code><code>cur.executemany(sql, param)</code>

<code>        </code><code>'''</code>

<code>        </code><code>sql_lines = []</code>

<code>        </code><code>with open('1.txt', 'r') as file:</code>

<code>            </code><code>for lines in file.readlines():</code>

<code>                </code><code>line = lines.strip('\n').split()</code>

<code>                </code><code>sql = 'insert a(ip,yy) values({0});'.format(line)</code>

<code>                </code><code>sql_lines.append(sql)</code>

<code>        </code><code>sql_last = '\r\n'.join(sql_lines)</code>

<code>        </code><code>cur.execute(sql_last)</code>

<code>        </code><code># cur.execute("INSERT INTO Writers(Name) VALUES('Honore de Balzac')")</code>

<code>        </code><code># cur.execute("INSERT INTO Writers(Name) VALUES('Lion Feuchtwanger')")</code>

<code>        </code><code># cur.execute("INSERT INTO Writers(Name) VALUES('Emile Zola')")</code>

<code>        </code><code># cur.execute("INSERT INTO Writers(Name) VALUES('Truman Capote')")</code>

<code>def</code> <code>db_execute(sql):</code>

<code>    </code><code>cursor </code><code>=</code> <code>con.cursor()</code>

<code>    </code><code>cursor.execute(sql)</code>

<code>    </code><code>cursor.close()</code>

<code>def</code> <code>read_file(file_path):</code>

<code>    </code><code>sql_lines </code><code>=</code> <code>[]</code>

<code>    </code><code>with </code><code>open</code><code>(file_path, </code><code>'r'</code><code>) as </code><code>file</code><code>:</code>

<code>        </code><code>for</code> <code>lines </code><code>in</code> <code>file</code><code>.readlines():</code>

<code>            </code><code>line </code><code>=</code> <code>lines.strip(</code><code>'\n'</code><code>).split()</code>

<code>            </code><code># sql = 'insert table(field) values({0});'.format(line)</code>

<code>            </code><code>sql_lines.append(line)</code>

<code>    </code><code>print</code> <code>sql_lines</code>

<code>    </code><code>return</code> <code>sql_lines</code>

<code>    </code><code># print '\r\n'.join(str(sql_lines)) python3用的</code>

<code>sql_lines </code><code>=</code> <code>read_file(</code><code>'1.txt'</code><code>)</code>

<code># db_execute(sql_lines)</code>

<code>test1</code><code>=</code><code>test(sql_lines)</code>

<code># test1=test()</code>

cat 2.txt

<code>192.1</code><code>.</code><code>1.121</code> <code>tomcat</code>

<code>192.1</code><code>.</code><code>1.122</code> <code>redis,mongodb,tomcat</code>

<code>python </code><code>2.py</code>

<code>        </code><code>sql </code><code>=</code> <code>'INSERT INTO a(ip,apply) VALUES(%s,%s)'</code>

<code>def</code> <code>read_file_2(file_path):</code>

<code>    </code><code>applylast </code><code>=</code> <code>[]</code>

<code>            </code><code>ip </code><code>=</code> <code>line[</code><code>0</code><code>]</code>

<code>            </code><code>apply</code> <code>=</code> <code>line[</code><code>1</code><code>].split(</code><code>','</code><code>)</code>

<code>            </code><code>for</code> <code>i </code><code>in</code> <code>range</code><code>(</code><code>len</code><code>(</code><code>apply</code><code>)):</code>

<code>                </code><code>applylist </code><code>=</code> <code>[ip, </code><code>apply</code><code>[i]]</code>

<code>                </code><code>applylast.append(applylist)</code>

<code>    </code><code>return</code> <code>applylast</code>

<code>sql_lines </code><code>=</code> <code>read_file_2(</code><code>'2.txt'</code><code>)</code>

<code># ####</code>

<code></code>

本文转自 liqius 51CTO博客，原文链接：http://blog.51cto.com/szgb17/1971040，如需转载请自行联系原作者