サンプルコード: SQLAlchemy を使用して Oracle に日付フィールドを保存する方法

2024-07-27

SQLAlchemy を使用して Oracle に日付フィールドを保存する方法

このガイドでは、SQLAlchemy を使用して Oracle データベースに日付フィールドを保存する方法について説明します。

前提条件

このガイドを完了するには、以下のものが必要です。

Python 3.x
SQLAlchemy
cx_Oracle

手順

データベース接続の作成

最初に、Oracle データベースへの接続を作成する必要があります。これを行うには、次のコードを使用できます。

from sqlalchemy import create_engine

engine = create_engine("oracle://username:password@host:port/sid")

上記コードで、username は Oracle ユーザー名、password はパスワード、host はデータベースホスト名、port はデータベースポート番号、sid はサービスIDに置き換えます。

テーブルの作成

次に、日付フィールドを含むテーブルを作成する必要があります。これを行うには、次のコードを使用できます。

from sqlalchemy import Column, Integer, Date
from sqlalchemy.ext.declarative import declarative_base

Base = declarative_base()

class MyTable(Base):
    __tablename__ = "my_table"

    id = Column(Integer, primary_key=True)
    date_field = Column(Date)

上記コードで、MyTable はテーブル名、id はプライマリキー列、date_field は日付フィールドに置き換えます。

レコードの作成

from datetime import date

session = engine.session()

record = MyTable(date_field=date.today())
session.add(record)
session.commit()

上記コードで、date.today() は現在の日付を取得します。

レコードのクエリ

from sqlalchemy.orm import query

session = engine.session()

records = session.query(MyTable).all()

for record in records:
    print(record.date_field)

上記コードで、records は日付フィールドを含むすべてのレコードのリストです。

Oracle データベースでは、日付フィールドは DATE データ型で保存されます。
SQLAlchemy は、日付フィールドを Python の datetime オブジェクトに変換します。
日付フィールドを保存する前に、datetime オブジェクトを DATE データ型に変換する必要があります。

追加情報

from sqlalchemy import create_engine

engine = create_engine("oracle://username:password@host:port/sid")

上記コードは、Oracle データベースへの接続を作成します。

from sqlalchemy import Column, Integer, Date
from sqlalchemy.ext.declarative import declarative_base

Base = declarative_base()

class MyTable(Base):
    __tablename__ = "my_table"

    id = Column(Integer, primary_key=True)
    date_field = Column(Date)

説明:

上記コードは、my_table という名前のテーブルを作成します。
id はプライマリキー列で、int 型です。
date_field は日付フィールドで、date 型です。

from datetime import date

session = engine.session()

record = MyTable(date_field=date.today())
session.add(record)
session.commit()

上記コードは、date_field に現在の日付を設定したレコードを作成します。
session.add(record) は、レコードをセッションに追加します。
session.commit() は、変更をコミットします。

from sqlalchemy.orm import query

session = engine.session()

records = session.query(MyTable).all()

for record in records:
    print(record.date_field)

上記コードは、my_table テーブル内のすべてのレコードをクエリします。
records は、クエリ結果を含むリストです。
for ループは、リスト内の各レコードを反復処理します。
print(record.date_field) は、各レコードの日付フィールドを出力します。

データベース接続情報、テーブル名、列名などは、必要に応じて変更してください。

from sqlalchemy import Column, Integer, Date, func
from sqlalchemy.ext.declarative import declarative_base

Base = declarative_base()

class MyTable(Base):
    __tablename__ = "my_table"

    id = Column(Integer, primary_key=True)
    date_field = Column(Date)

session = engine.session()

date_str = "2024-06-13"
record = MyTable(date_field=func.to_date(date_str))
session.add(record)
session.commit()

sqlalchemy.types.Date() 型を使用する

sqlalchemy.types.Date() 型を使用して、Python の datetime オブジェクトを Oracle の DATE データ型に変換することができます。

from sqlalchemy import Column, Integer, Date
from sqlalchemy.types import Date
from sqlalchemy.ext.declarative import declarative_base

Base = declarative_base()

class MyTable(Base):
    __tablename__ = "my_table"

    id = Column(Integer, primary_key=True)
    date_field = Column(Date)

session = engine.session()

from datetime import datetime

date_obj = datetime.strptime("2024-06-13", "%Y-%m-%d")
record = MyTable(date_field=Date(date_obj))
session.add(record)
session.commit()

INSERT ステートメントを使用する

INSERT ステートメントを使用して、日付フィールドを含むレコードを直接 Oracle データベースに挿入することができます。

from sqlalchemy import text

session = engine.session()

sql = text(
    "INSERT INTO my_table (id, date_field) VALUES (:id, :date_field)"
)

session.execute(sql, id=1, date_field=datetime.today())
session.commit()

cx_Oracle を使用する

cx_Oracle を使用して、Oracle データベースに直接クエリを実行し、日付フィールドを含むレコードを挿入することができます。

import cx_Oracle

connection = cx_Oracle.connect("username/password@host:port/sid")
cursor = connection.cursor()

cursor.execute(
    "INSERT INTO my_table (id, date_field) VALUES (:id, :date_field)",
    id=1,
    date_field=datetime.today(),
)

connection.commit()
connection.close()