-
Notifications
You must be signed in to change notification settings - Fork 0
/
sql_demo.py
71 lines (62 loc) · 3.01 KB
/
sql_demo.py
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
63
64
65
66
67
68
69
70
# -*- coding: utf-8 -*-
import MySQLdb
import sys
import csv
import exceptions
import time
import multiprocessing
import gc
# Structure of Table JOB_IO_INFO
'''
+-----------------------+--------------+------+-----+---------+-------+
| Field | Type | Null | Key | Default | Extra |
+-----------------------+--------------+------+-----+---------+-------+
| JOBID | varchar(20) | NO | PRI | NULL | |
| PROGRAM_NAME | varchar(500) | NO | | NULL | |
| CNC | int(11) | NO | | NULL | |
| IOBW_READ_SUM | double | YES | | NULL | |
| IOBW_READ_COUNT | int(11) | YES | | NULL | |
| IOBW_READ_AVERAGE | double | YES | | NULL | |
| IOBW_WRITE_SUM | double | YES | | NULL | |
| IOBW_WRITE_COUNT | int(11) | YES | | NULL | |
| IOBW_WRITE_AVERAGE | double | YES | | NULL | |
| IOBW_ALL_COUNT | int(11) | YES | | NULL | |
| IOPS_READ_SUM | double | YES | | NULL | |
| IOPS_READ_COUNT | int(11) | YES | | NULL | |
| IOPS_READ_AVERAGE | double | YES | | NULL | |
| IOPS_WRITE_SUM | double | YES | | NULL | |
| IOPS_WRITE_COUNT | int(11) | YES | | NULL | |
| IOPS_WRITE_AVERAGE | double | YES | | NULL | |
| IOPS_ALL_COUNT | int(11) | YES | | NULL | |
| IOTIME_COUNT | int(11) | YES | | NULL | |
| MDS_OPEN_SUM | int(11) | YES | | NULL | |
| MDS_OPEN_COUNT | int(11) | YES | | NULL | |
| MDS_OPEN_AVERAGE | double | YES | | NULL | |
| MDS_CLOSE_SUM | int(11) | YES | | NULL | |
| MDS_CLOSE_COUNT | int(11) | YES | | NULL | |
| MDS_CLOSE_AVERAGE | double | YES | | NULL | |
| MDS_ALL_COUNT | int(11) | YES | | NULL | |
| PROCESS_READ_MAX | int(11) | YES | | NULL | |
| PROCESS_WRITE_MAX | int(11) | YES | | NULL | |
| FILENAME_UNIQUE_COUNT | int(11) | YES | | NULL | |
| JOB_NAME | varchar(500) | YES | | NULL | |
+-----------------------+--------------+------+-----+---------+-------+
'''
def get_jobid():
jobid = []
conn = MySQLdb.connect(host='20.0.2.201', user='root', db='JOB_IO', passwd='', port=3306)
cursor = conn.cursor()
sql = "select * from JOB_IO_INFO where JOBID = 42606463;"
cursor.execute(sql)
result = cursor.fetchall()
for res in result:
print res
#jobid.append(str(res)[2:-3])
#for job in jobid:
#print job
conn.commit()
cursor.close()
conn.close()
return jobid
if __name__ == "__main__":
jobid = get_jobid()