- MySQLを使用する場合の例:
import mysql.connector
# データベース接続の設定
config = {
'user': 'ユーザー名',
'password': 'パスワード',
'host': 'ホスト名',
'database': 'データベース名',
}
# データベース接続の確立
conn = mysql.connector.connect(config)
cursor = conn.cursor()
# SQLファイルからデータベースをインポートするクエリ
with open('データベースファイル.sql', 'r') as file:
sql_script = file.read()
cursor.execute(sql_script)
conn.commit()
# 接続を閉じる
cursor.close()
conn.close()
- PostgreSQLを使用する場合の例:
import psycopg2
# データベース接続の設定
config = {
'dbname': 'データベース名',
'user': 'ユーザー名',
'password': 'パスワード',
'host': 'ホスト名',
'port': 'ポート番号',
}
# データベース接続の確立
conn = psycopg2.connect(config)
cursor = conn.cursor()
# SQLファイルからデータベースをインポートするクエリ
with open('データベースファイル.sql', 'r') as file:
sql_script = file.read()
cursor.execute(sql_script)
conn.commit()
# 接続を閉じる
cursor.close()
conn.close()
上記のコード例では、それぞれMySQLとPostgreSQLを使用していますが、他のデータベース管理システムでも同様の手順が適用できます。適切なデータベース接続設定を指定し、open
関数を使用してSQLファイルを読み込み、execute
関数を使用してクエリを実行します。最後に、変更を確定させるためにcommit
を呼び出し、接続を閉じます。
これらの方法を使用することで、SQLファイルからデータベースをインポートすることができます。この手法を活用して、データベースの管理やデータの移行をスムーズに行うことができます。