Python を使用して MySQL データベースを操作する方法

1. 背景

今回は Python3.6 環境を使用し、Anaconda ノートブックで接続実験を行いましたが、もちろん Python シェルでも操作できます。

MySQL データベースに接続するために最も一般的に使用され、安定した Python ライブラリは PyMySQL です。

2. 基本操作

1. PyMySQL ライブラリをインストールします

最も簡単な方法:

コマンドラインに入力しますpip install pymysql

または:

インストール用の whl ファイル [1] をダウンロードします。インストール プロセスは自分で行います。

2. MySQL データベースのインストール

MySQL データベースには

MySQL と MariaDB

の 2 つがあります。私は MySQL のフォークである MariaDB を使用しています。

両者はパフォーマンスのほとんどの面で互換性があり、使用中に違いを感じることはありません。

はダウンロード アドレスを示します: MySQL[2]、MariaDB[3]、インストール プロセスは非常に簡単です。次のステップに従うだけですが、パスワードを覚えておいてください。

ちょっとしたエピソードがありますが、MySQL と MariaDB は姉妹と姉妹の関係に相当し、同じ人 ( Widenius ) によって作成されました。

MySQL が Oracle に買収された後、ワイドニウス氏は不満を感じ、MySQL を完全に置き換えることができる MariaDB を構築しました。

ダニエルは故意です。

3. SQL の基本構文

次に、SQL テーブルの作成、クエリ、データ挿入などの関数を使用して、SQL 言語の基本的な文を簡単に紹介します。

• データベースの表示: SHOW DATABASES;

• データベースの作成: CREATE DATEBASE データベース名;

• データベースの使用: USE データベース名;

• データ テーブルの表示:SHOW TABLES;

• データテーブルの作成: CREATE TABLE テーブル名 (列名 1 (データ型 1)、列名 2 (データ型 2));

• データの挿入: INSERT INTO テーブル名 (列名 1、列名 2) VALUES (データ 1、データ 2);

• データの表示:

  SELECT * FROM テーブル名;

• データの更新:

  UPDATE テーブル名 SET カラム名 1 = 新しいデータ 1、カラム名 2 =新しいデータ 2 WHERE 特定の列 = 特定のデータ;

4. データベースへの接続

必要なファイルとライブラリをインストールしたら、正式に接続を開始しますデータベースへ まあ、不思議だけど難しくはない！

#首先导入PyMySQL库
import pymysql
#连接数据库，创建连接对象connection
#连接对象作用是：连接数据库、发送数据库信息、处理回滚操作（查询中断时，数据库回到最初状态）、创建新的光标对象
connection = pymysql.connect(host = 'localhost' #host属性
                            user = 'root' #用户名
                            password = '******'  #此处填登录数据库的密码
                            db = 'mysql' #数据库名
                            )

このコードを実行すると接続が完了します。

5. 追加、削除、変更、およびクエリ操作

最初にどのデータベースがあるかを確認します:

#创建光标对象，一个连接可以有很多光标，一个光标跟踪一种数据状态。
#光标对象作用是：、创建、删除、写入、查询等等
cur = connection.cursor()
#查看有哪些数据库，通过cur.fetchall()获取查询所有结果
print(cur.fetchall())

すべてのデータベースを出力します:

(('information_schema',),
('law',),
('mysql',),
('performance_schema',),
('test',))

Create inテスト データベース テーブル:

#使用数据库test
cur.execute('USE test')
#在test数据库里创建表student，有name列和age列
cur.execute('CREATE TABLE student(name VARCHAR(20),age TINYINT(3))')

データ テーブルにデータを挿入する学生:

sql = 'INSERT INTO student (name,age) VALUES (%s,%s)'
cur.execute(sql,('XiaoMing',23))

データ テーブルの内容を表示する学生:

cur.execute('SELECT * FROM student')
print(cur.fetchone())

出力は次のとおりです。 ('シャオミン'、23)

ビンゴ!これは挿入したばかりのデータです。

最後に、カーソルと接続を忘れずに閉じてください。

#关闭连接对象，否则会导致连接泄漏，消耗数据库资源
connection.close()
#关闭光标
cur.close()

OK、プロセス全体は大まかに次のようになります。

もちろん、これらは非常に基本的な操作です。その他の使用方法については、

PyMySQL 公式ドキュメント [4] を参照してください。

3. ビッグ データ ファイルのインポート

csv ファイルを例に挙げます。csv ファイルをデータベースにインポートするには、通常 2 つの方法があります:

1. 1 つずつインポートします。 SQL の挿入メソッドを使用します。データ量の少ない CSV ファイルに適しています。ここでは詳しく説明しません。

2. データのロード方法によるインポートは高速であり、ビッグ データ ファイルに適していますが、これがこの記事の焦点でもあります。

サンプル CSV ファイルは次のとおりです:

全体の作業は 3 つのステップに分かれています:

1. Python を使用して接続しますmysql データベースへ;

2、基于CSV文件表格字段创建表；

3、使用load data方法导入CSV文件内容。

sql的load data语法简介：

LOAD DATA LOCAL INFILE 'csv_file_path' INTO TABLE table_name FIELDS TERMINATED BY ',' LINES TERMINATED BY '\\r\\n' IGNORE 1 LINES

csv_file_path 指文件绝对路径 table_name指表名称 FIELDS TERMINATED BY ','指以逗号分隔 LINES TERMINATED BY '\\r\\n'指换行 IGNORE 1 LINES指跳过第一行，因为第一行是表的字段名

下面给出全部代码：

#导入pymysql方法
import pymysql


#连接数据库
config = {:'',
         :3306,
         :'username',
         :'password',
         :'utf8mb4',
         :1
         }
conn = pymysql.connect(**config)
cur = conn.cursor()


#load_csv函数，参数分别为csv文件路径，表名称，数据库名称
def load_csv(csv_file_path,table_name,database='evdata'):
   #打开csv文件
   file = open(csv_file_path, 'r',encoding='utf-8')
   #读取csv文件第一行字段名，创建表
   reader = file.readline()
   b = reader.split(',')
   colum = ''
   for a in b:
       colum = colum + a + ' varchar(255),'
   colum = colum[:-1]
   #编写sql，create_sql负责创建表，data_sql负责导入数据
   create_sql = 'create table if not exists ' + table_name + ' ' + '(' + colum + ')' + ' DEFAULT CHARSET=utf8'
   data_sql = "LOAD DATA LOCAL INFILE '%s' INTO TABLE %s FIELDS TERMINATED BY ',' LINES TERMINATED BY '\\r\\n' IGNORE 1 LINES" % (csv_filename,table_name)

   #使用数据库
   cur.execute('use %s' % database)
   #设置编码格式
   cur.execute('SET NAMES utf8;')
   cur.execute('SET character_set_connection=utf8;')
   #执行create_sql，创建表
   cur.execute(create_sql)
   #执行data_sql，导入数据
   cur.execute(data_sql)
   conn.commit()
   #关闭连接
   conn.close()
   cur.close()

以上がPython を使用して MySQL データベースを操作する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。