Python数据分析之第五章（案例之链接mysql数据库）

本文主要是介绍Python数据分析之第五章（案例之链接mysql数据库），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

（1）安装数据库

转到目录：D:\python36\Scripts

pip install MySQLClient

填写图片摘要（选填）

（2）导入TXT文件

代码：

# -*- coding: utf-8 -*-

"""

Created on Fri Apr 20 10:22:25 2018

@author: LingtingWu

"""

import os;

import pandas;

import MySQLdb;

import matplotlib;

import matplotlib.pyplot as plt;

connection = MySQLdb.connect(

    host='localhost',

    user='root',

    passwd='123456',

    db='7.1',

    charset='utf8'

);

#导入数据到MySQL

#遍历目录，把里面的所有数据入库

rootDir="D:\\Python\\7.1\\";

def exeSQL(sql):

    print("exeSQL: " + sql)

    connection.query(sql);    

for fileName in os.listdir(rootDir): 

    path = os.path.join(rootDir, fileName)     

    if ".txt" in fileName:

        print(path)

        path = path.replace("\\", "\\\\");

        #拿到文件名中的时间字段

        datetime = fileName[0:8];

        tableName = "订购明细" + datetime;

        #建表、导入数据到表中

        exeSQL("drop table if exists " + tableName)

        exeSQL("create table " + tableName + "(订单编号 int, 订购日期 datetime, 用户ID int, 产品 char(8), `单价(元)` int, 数量 int, 订购金额 int);");

        exeSQL("LOAD DATA LOCAL INFILE '" + path + "' INTO TABLE `" + tableName + "` CHARACTER SET 'UTF8' COLUMNS TERMINATED BY ',' LINES TERMINATED BY '\\n' IGNORE 1 LINES;");       

        #建立日订购统计表

        exeSQL("create table if not exists 日订购统计表(统计日期 date, 订购用户数 int, 订购次数 int, 人均订购金额 double, 订购总额 double);");

        exeSQL("delete from 日订购统计表 where 统计日期='" + datetime + "';");

        exeSQL("insert into 日订购统计表 select '" + datetime + "', count(distinct 用户ID), count(用户ID), sum(订购金额)/count(distinct 用户ID), sum(订购金额) from `" + tableName + "`;");

statDay = pandas.read_sql('select * from 日订购统计表;', con=connection);

#记得用完要关闭连接

connection.close();

print('\n日订购统计表数据如下:');

print(statDay);

#绘图

font = {

    'family' : 'SimHei'

}

matplotlib.rc('font', **font);

plot1 = plt.plot(statDay['统计日期'], statDay['订购用户数']);

plot2 = plt.plot(statDay['统计日期'], statDay['订购次数']);

plot3 = plt.plot(statDay['统计日期'], statDay['人均订购金额']);

plt.show();

plt.legend(('订购用户数', '订购次数', '人均订购金额'))

【遇到的问题】

ProgrammingError: (1064, "You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'ROW 1' at line 1")

【解决办法】

ROW->LINES;

 

 

这篇关于Python数据分析之第五章（案例之链接mysql数据库）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---