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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
tomcat
192.1
.
1.121
redis
192.1
.
1.122
mongodb
192.1
.
1.122
tomcat
192.1
.
1.122
tomcat
192.1
.
1.123
redis
192.1
.
1.124
mongodb
192.1
.
1.124
tomcat
192.1
.
1.124
other
192.1
.
1.125
tomcat
192.1
.
1.126
fastdfs
192.1
.
1.127
fastdfs
192.1
.
1.128
fastdfs
192.1
.
1.129
other
192.1
.
1.130
other
192.1
.
1.131
fastdfs
192.1
.
1.132
fastdfs
192.1
.
1.133
|
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
python
1.py
#!/usr/bin/env python
# -*- coding: utf-8 -*-
import
sys
#import pymysql
#pymysql.install_as_MySQLdb()
import
MySQLdb as mdb
con
=
mdb.connect(
'127.0.0.1'
,
'root'
,
'123456'
,
'db03'
)
def
test(param):
with con:
cur
=
con.cursor()
# cur.execute("CREATE TABLE IF NOT EXISTS \
# Writers(Id INT PRIMARY KEY AUTO_INCREMENT, Name VARCHAR(25))";"INSERT INTO Writers(Name) VALUES('Jack London')")
# cur.execute("INSERT INTO Writers(Name) VALUES('Jack London'),INSERT INTO Writers(Name) VALUES('Honore de Balzac')")
# sql = 'INSERT INTO Writers(Name) VALUES(%s)'
# param = ('Jack London', 'Honore de Balzac')
# cur.executemany(sql, param)
# sql="insert a(ip,yy) values(['tomcat', '192.1.1.121']); insert a(ip,yy) values(['redis', '192.1.1.122']);"
# cur.execute(sql)
sql
=
'INSERT INTO a(apply,ip) VALUES(%s,%s)'
#param = [['tomcat', '192.1.1.121'], ['redis', '192.1.1.122'], ['mongodb', '192.1.1.122']]
#param = ((username1, salt1, pwd1), (username2, salt2, pwd2), (username3, salt3, pwd3))
cur.executemany(sql, param)
'''
sql_lines = []
with open('1.txt', 'r') as file:
for lines in file.readlines():
line = lines.strip('\n').split()
sql = 'insert a(ip,yy) values({0});'.format(line)
sql_lines.append(sql)
sql_last = '\r\n'.join(sql_lines)
cur.execute(sql_last)
# cur.execute("INSERT INTO Writers(Name) VALUES('Honore de Balzac')")
# cur.execute("INSERT INTO Writers(Name) VALUES('Lion Feuchtwanger')")
# cur.execute("INSERT INTO Writers(Name) VALUES('Emile Zola')")
# cur.execute("INSERT INTO Writers(Name) VALUES('Truman Capote')")
'''
def
db_execute(sql):
cursor
=
con.cursor()
cursor.execute(sql)
cursor.close()
def
read_file(file_path):
sql_lines
=
[]
with
open
(file_path,
'r'
) as
file
:
for
lines
in
file
.readlines():
line
=
lines.strip(
'\n'
).split()
# sql = 'insert table(field) values({0});'.format(line)
sql_lines.append(line)
print
sql_lines
return
sql_lines
# print '\r\n'.join(str(sql_lines)) python3用的
sql_lines
=
read_file(
'1.txt'
)
# db_execute(sql_lines)
test1
=
test(sql_lines)
# test1=test()
|
cat 2.txt
|
1
2
|
192.1
.
1.121
tomcat
192.1
.
1.122
redis,mongodb,tomcat
|
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
python
2.py
#!/usr/bin/env python
# -*- coding: utf-8 -*-
import
sys
#import pymysql
#pymysql.install_as_MySQLdb()
import
MySQLdb as mdb
con
=
mdb.connect(
'127.0.0.1'
,
'root'
,
'123456'
,
'db03'
)
def
test(param):
with con:
cur
=
con.cursor()
sql
=
'INSERT INTO a(ip,apply) VALUES(%s,%s)'
cur.executemany(sql, param)
def
db_execute(sql):
cursor
=
con.cursor()
cursor.execute(sql)
cursor.close()
def
read_file(file_path):
sql_lines
=
[]
with
open
(file_path,
'r'
) as
file
:
for
lines
in
file
.readlines():
line
=
lines.strip(
'\n'
).split()
sql_lines.append(line)
print
sql_lines
return
sql_lines
def
read_file_2(file_path):
applylast
=
[]
with
open
(file_path,
'r'
) as
file
:
for
lines
in
file
.readlines():
line
=
lines.strip(
'\n'
).split()
ip
=
line[
0
]
apply
=
line[
1
].split(
','
)
for
i
in
range
(
len
(
apply
)):
applylist
=
[ip,
apply
[i]]
applylast.append(applylist)
return
applylast
sql_lines
=
read_file_2(
'2.txt'
)
test1
=
test(sql_lines)
# ####
|
本文转自 liqius 51CTO博客，原文链接：http://blog.51cto.com/szgb17/1971040，如需转载请自行联系原作者
