Ce qui suit est un exemple de lecture et d'insertion de données MySQL avec des pandas python3. Il a une bonne valeur de référence et j'espère qu'il sera utile à tout le monde. Venez jeter un oeil ensemble
Le code python est le suivant :
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 | # -*- coding:utf-8 -*-
import pandas as pd
import pymysql
import sys
from sqlalchemy import create_engine
def read_mysql_and_insert():
try :
conn = pymysql.connect(host='localhost',user='user1',password='123456',db='test',charset='utf8')
except pymysql.err.OperationalError as e:
print ('Error is '+str(e))
sys. exit ()
try :
engine = create_engine('mysql+pymysql:
except sqlalchemy.exc.OperationalError as e:
print ('Error is '+str(e))
sys. exit ()
except sqlalchemy.exc.InternalError as e:
print ('Error is '+str(e))
sys. exit ()
try :
sql = 'select * from sum_case'
df = pd.read_sql(sql, con=conn)
except pymysql.err.ProgrammingError as e:
print ('Error is '+str(e))
sys. exit ()
print (df.head())
df.to_sql(name='sum_case_1',con=engine,if_exists='append',index=False)
conn.close()
print ('ok')
if __name__ == '__main__':
df = read_mysql_and_insert()
|
Copier après la connexion
Il y a d'autres choses à noter.
1) Il y a deux tables dans la base de données de test. Les instructions de création de table sont les suivantes :
1 2 3 4 5 | CREATE TABLE `sum_case` (
`type_id` tinyint(2) DEFAULT NULL,
`type_name` varchar(5) DEFAULT NULL,
KEY `b` (`type_name`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
|
Copier après la connexion
1 2 3 4 5 | CREATE TABLE `sum_case_1` (
`type_id` tinyint(2) DEFAULT NULL,
`type_name` varchar(5) DEFAULT NULL,
KEY `b` (`type_name`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
|
Copier après la connexion
Insérer les données initiales
1 | insert into sum_case (type_id,type_name) values (1,'a'),(2,'b'),(3,'c')
|
Copier après la connexion
2) Créer un utilisateur1
1 | grant select, update,insert on test.* to 'user1'@'localhost' identified by '123456'
|
Copier après la connexion
Recommandations associées :
Méthode Python d'extraction des enregistrements d'emplacement spécifiés après le regroupement groupby
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!