xdc_git_python_20210511/python_base/day9/获取系统信息并写入数据库.py

# -*- coding: UTF-8 -*-

import subprocess
import pymysql



info_dict = {}


def run_cmd(cmd):
    stat, result = subprocess.getstatusoutput(cmd)
    return result
    if not stat:
        print(stat)
        return parse(result)


def parse(data):
    if data.endswith('_'):
        data = data[:-1]
    return data

# print(run_cmd("uname -r"))


def get_base():
    result = {
    'os_name': run_cmd("uname -r").strip(),
    'os_version': run_cmd("uname -m").strip()
    }
    return result

info_dict.update(get_base())
print(info_dict)

conn = pymysql.connect(
    host='a.xdc.ink',
    port=3306,
    user='xdc',
    passwd='Xdc123@a',
    db='cmd',
    charset='utf8mb4'
)

print(info_dict)

cursor = conn.cursor() 


# create_tabel_sql = """create table cpu_s
# (id int auto_increment primary key,
# uname varchar(230) not null,
# info varchar(230) not null
# )"""
# row = cursor.execute(create_tabel_sql)
# print(row)

insert_data_sql = "insert into cpu_s(uname, info) value(%s, %s);"  # pymsql 的字符串格式化
for k,v in info_dict.items():
    print(k,v)
    data_a = "{:s}".format(k)
    data_b = "{:s}".format(v)
    data = [(data_a,data_b)] # 定义为列表
    row = cursor.executemany(insert_data_sql,data)  # 传入类型为元组或者列表
    print(row)

conn.commit() # 修改数据库内容要提交
cursor.close()
conn.close()

"""
操作系统
系统架构
主机名
内核信息
"""