Pythonを使ったSQLiteとCSVファイルの連携方法：実践ガイド

import sqlite3

# データベースに接続する
conn = sqlite3.connect('example.db')

# カーソルを作成する
cur = conn.cursor()

# テーブルを作成するSQL文
create_table_sql = '''
CREATE TABLE IF NOT EXISTS users (
    id INTEGER PRIMARY KEY,
    name TEXT NOT NULL,
    age INTEGER
)
'''
# SQL文を実行する
cur.execute(create_table_sql)

# 変更を保存する
conn.commit()

# 接続をクローズする
conn.close()

import sqlite3

# 新しいデータベースファイルexample.dbを作成または接続する
conn = sqlite3.connect('new_example.db')

# カーソルを作成する
cur = conn.cursor()

# 新しいテーブルを定義するSQL文
create_table_sql = '''
CREATE TABLE IF NOT EXISTS products (
    id INTEGER PRIMARY KEY,
    name TEXT NOT NULL,
    price REAL
)
'''
# SQL文を実行してテーブルを作成する
cur.execute(create_table_sql)

# categoriesテーブルを定義するSQL文
create_categories_table_sql = '''
CREATE TABLE IF NOT EXISTS categories (
    id INTEGER PRIMARY KEY,
    name TEXT NOT NULL
)
'''
# SQL文を実行してcategoriesテーブルを作成する
cur.execute(create_categories_table_sql)

# テーブルリストを取得するSQL文
cur.execute("SELECT name FROM sqlite_master WHERE type='table';")

# 結果を取得して表示する
tables = cur.fetchall()
print("Tables in the database:", tables)

# 変更を保存する
conn.commit()

# 接続をクローズする
conn.close()

import sqlite3

# データベースに接続する
conn = sqlite3.connect('new_example.db')
cur = conn.cursor()

# 挿入するデータ
product_data = (1, 'Laptop', 1200.99)

# データを挿入するSQL文
insert_product_sql = 'INSERT INTO products (id, name, price) VALUES (?, ?, ?)'

# SQL文を実行する
cur.execute(insert_product_sql, product_data)

# 挿入するデータのリスト
multiple_products_data = [
    (2, 'Smartphone', 799.99),
    (3, 'Tablet', 499.99),
    (4, 'Monitor', 199.99)
]

# データを一括挿入するSQL文
cur.executemany(insert_product_sql, multiple_products_data)

# データを取得するSQL文
cur.execute('SELECT * FROM products')

# 結果を取得して表示する
rows = cur.fetchall()
for row in rows:
    print(row)

try:
    # データを挿入する
    cur.execute(insert_product_sql, (5, 'Keyboard', 49.99))
    conn.commit()
except sqlite3.Error as e:
    print("An error occurred:", e)
    conn.rollback()

# 変更を保存する
conn.commit()

# 接続をクローズする
conn.close()

import sqlite3

# データベースに接続する
conn = sqlite3.connect('new_example.db')
cur = conn.cursor()

# データを取得するSQL文
cur.execute('SELECT * FROM products')

# 結果を取得して表示する
rows = cur.fetchall()
for row in rows:
    print(row)

# 条件付きでデータを取得するSQL文
cur.execute('SELECT * FROM products WHERE price >= 500')

# 結果を取得して表示する
rows = cur.fetchall()
for row in rows:
    print(row)

# 特定の列を取得するSQL文
cur.execute('SELECT name, price FROM products')

# 結果を取得して表示する
rows = cur.fetchall()
for row in rows:
    print(row)

# データを昇順で取得するSQL文
cur.execute('SELECT * FROM products ORDER BY price ASC')

# 結果を取得して表示する
rows = cur.fetchall()
for row in rows:
    print(row)

# データの行数を制限するSQL文
cur.execute('SELECT * FROM products LIMIT 2')

# 結果を取得して表示する
rows = cur.fetchall()
for row in rows:
    print(row)

# 接続をクローズする
conn.close()

import csv

# CSVファイルを読み込む
with open('sample.csv', newline='') as csvfile:
    csvreader = csv.reader(csvfile)

    # ヘッダーを読み込む
    header = next(csvreader)
    print('Header:', header)

    # データを読み込む
    for row in csvreader:
        print(row)

# CSVファイルを読み込む
with open('sample.csv', newline='') as csvfile:
    csvreader = csv.reader(csvfile)

    # データをリストとして取得する
    data = list(csvreader)
    for row in data:
        print(row)

# CSVファイルを辞書形式で読み込む
with open('sample.csv', newline='') as csvfile:
    csvreader = csv.DictReader(csvfile)

    # データを読み込む
    for row in csvreader:
        print(row)

try:
    with open('sample.csv', newline='') as csvfile:
        csvreader = csv.reader(csvfile)

        # ヘッダーを読み込む
        header = next(csvreader)
        print('Header:', header)

        # データを読み込む
        for row in csvreader:
            print(row)
except FileNotFoundError:
    print("CSVファイルが見つかりません。")
except Exception as e:
    print("エラーが発生しました:", e)

import csv
import sqlite3

# CSVファイルを読み込む
with open('sample.csv', newline='') as csvfile:
    csvreader = csv.reader(csvfile)
    header = next(csvreader)  # ヘッダーを読み込む
    data = list(csvreader)  # データをリストとして取得

# SQLiteデータベースに接続する
conn = sqlite3.connect('new_example.db')
cur = conn.cursor()

# テーブルが存在しない場合は作成する
create_table_sql = '''
CREATE TABLE IF NOT EXISTS products (
    id INTEGER PRIMARY KEY,
    name TEXT NOT NULL,
    price REAL
)
'''
cur.execute(create_table_sql)

# データを挿入するSQL文
insert_product_sql = 'INSERT INTO products (id, name, price) VALUES (?, ?, ?)'

# データを一括挿入する
cur.executemany(insert_product_sql, data)

# データを取得して表示する
cur.execute('SELECT * FROM products')
rows = cur.fetchall()
for row in rows:
    print(row)

try:
    # データを一括挿入する
    cur.executemany(insert_product_sql, data)
    conn.commit()
except sqlite3.Error as e:
    print("An error occurred:", e)
    conn.rollback()

# 変更を保存する
conn.commit()

# 接続をクローズする
conn.close()

import sqlite3

# SQLiteデータベースに接続する
conn = sqlite3.connect('new_example.db')
cur = conn.cursor()

# データを取得するSQL文
cur.execute('SELECT * FROM products')

# 結果を取得してリストに格納する
rows = cur.fetchall()

import csv

# CSVファイルを作成する
with open('exported_data.csv', 'w', newline='') as csvfile:
    csvwriter = csv.writer(csvfile)

    # ヘッダーを書き込む
    header = ['id', 'name', 'price']
    csvwriter.writerow(header)

    # データを書き込む
    csvwriter.writerows(rows)

try:
    # CSVファイルを作成する
    with open('exported_data.csv', 'w', newline='') as csvfile:
        csvwriter = csv.writer(csvfile)

        # ヘッダーを書き込む
        header = ['id', 'name', 'price']
        csvwriter.writerow(header)

        # データを書き込む
        csvwriter.writerows(rows)
except Exception as e:
    print("An error occurred while exporting data:", e)

# CSVファイルを読み込んで内容を確認する
with open('exported_data.csv', newline='') as csvfile:
    csvreader = csv.reader(csvfile)
    for row in csvreader:
        print(row)

# 接続をクローズする
conn.close()

import csv
import sqlite3

# CSVファイルを読み込む
with open('sample.csv', newline='') as csvfile:
    csvreader = csv.reader(csvfile)
    header = next(csvreader)
    data = list(csvreader)

# SQLiteデータベースに接続する
conn = sqlite3.connect('analysis_example.db')
cur = conn.cursor()

# テーブルを作成する
cur.execute('''
CREATE TABLE IF NOT EXISTS sales (
    id INTEGER PRIMARY KEY,
    product_name TEXT NOT NULL,
    quantity INTEGER,
    price REAL,
    date TEXT
)
''')

# データを挿入する
insert_sql = 'INSERT INTO sales (id, product_name, quantity, price, date) VALUES (?, ?, ?, ?, ?)'
cur.executemany(insert_sql, data)

# 変更を保存する
conn.commit()

# 各製品の総売上を計算するSQL文
cur.execute('''
SELECT product_name, SUM(quantity * price) as total_sales
FROM sales
GROUP BY product_name
ORDER BY total_sales DESC
''')

# 結果を取得して表示する
results = cur.fetchall()
for row in results:
    print(f"Product: {row[0]}, Total Sales: {row[1]}")

# 月ごとの売上を計算するSQL文
cur.execute('''
SELECT strftime('%Y-%m', date) as month, SUM(quantity * price) as monthly_sales
FROM sales
GROUP BY month
ORDER BY month
''')

# 結果を取得して表示する
monthly_sales = cur.fetchall()
for row in monthly_sales:
    print(f"Month: {row[0]}, Monthly Sales: {row[1]}")

import matplotlib.pyplot as plt

# 月ごとの売上をグラフに表示する
months = [row[0] for row in monthly_sales]
sales = [row[1] for row in monthly_sales]

plt.plot(months, sales, marker='o')
plt.title('Monthly Sales')
plt.xlabel('Month')
plt.ylabel('Sales')
plt.xticks(rotation=45)
plt.tight_layout()
plt.show()

# レポートの作成
report = """
データ分析レポート

1. 各製品の総売上
------------------
"""
for row in results:
    report += f"Product: {row[0]}, Total Sales: {row[1]}\n"

report += "\n2. 月ごとの売上\n------------------\n"
for row in monthly_sales:
    report += f"Month: {row[0]}, Monthly Sales: {row[1]}\n"

# レポートをファイルに保存する
with open('sales_report.txt', 'w') as report_file:
    report_file.write(report)