growing hard days.

SQLAlchemyでjoinする

2016/12/18 2017/07/23

PythonのSQLAlchemyでMySQLのテーブルをjoinするときの覚書です。

モデルクラスはこんな感じでrelationを書いておきます。
例として社員マスタテーブルと給与支払テーブルのrelationとします。

models.py

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.sql.schema import Column
from sqlalchemy.orm import relation
from sqlalchemy.schema import ForeignKey
from sqlalchemy.dialects.mysql.base import (
    VARCHAR,
    INTEGER,
    BIGINT
)

Base = declarative_base()

class Employee(Base):
    __tablename__ = 'employee'

    employee_id = Column(INTEGER(unsigned=False), primary_key=True,nullable=True)
    name = Column(VARCHAR(length=45), nullable=False)

    payroll_payment = relation(
        'PayrollPayment',
        backref = 'employee',
        order_by = 'PayrollPayment.employee_id'
    )

    def __repr__(self):
        return '<Employee(%d, %s)>' % (self.employee_id, self.name)

class PayrollPayment(Base):
    __tablename__ = 'payroll_payment'

    payroll_payment_id = Column(INTEGER(unsigned=False), primary_key=True,nullable=True)

    employee_id = Column(
        INTEGER(unsigned=False),
        ForeignKey('employee.employee_id'),
        nullable=False
    )

    salary = Column(BIGINT(unsigned=True), nullable=False)
    salary_month = Column(INTEGER(unsigned=True), nullable=False)

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

38

39

40

41

42

from sqlalchemy.ext.declarative import declarative_base

from sqlalchemy.sql.schema import Column

from sqlalchemy.orm import relation

from sqlalchemy.schema import ForeignKey

from sqlalchemy.dialects.mysql.base import (

VARCHAR,

INTEGER,

BIGINT

)

Base = declarative_base()

class Employee(Base):

__tablename__ = 'employee'

employee_id = Column(INTEGER(unsigned=False), primary_key=True,nullable=True)

name = Column(VARCHAR(length=45), nullable=False)

payroll_payment = relation(

'PayrollPayment',

backref = 'employee',

order_by = 'PayrollPayment.employee_id'

)

def __repr__(self):

return '<Employee(%d, %s)>' % (self.employee_id, self.name)

class PayrollPayment(Base):

__tablename__ = 'payroll_payment'

payroll_payment_id = Column(INTEGER(unsigned=False), primary_key=True,nullable=True)

employee_id = Column(

INTEGER(unsigned=False),

ForeignKey('employee.employee_id'),

nullable=False

)

salary = Column(BIGINT(unsigned=True), nullable=False)

salary_month = Column(INTEGER(unsigned=True), nullable=False)

この例ではouter joinとして結合します。

## configとかは省略します

url = 'mysql+pymysql://' + config.db_username + ':' + config.db_password + '@' + config.db_host + '/' + config.db_name + '?charset=utf8'
engine = create_engine(url,echo=True)
Session = sessionmaker(bind=engine)
session = Session()

employee_tbl = models.Employee

result = session.query(
    employee_tbl.employee_id,
    employee_tbl.name
).outerjoin(
    employee_tbl.payroll_payment
).all()

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

## configとかは省略します

url = 'mysql+pymysql://' + config.db_username + ':' + config.db_password + '@' + config.db_host + '/' + config.db_name + '?charset=utf8'

engine = create_engine(url,echo=True)

Session = sessionmaker(bind=engine)

session = Session()

employee_tbl = models.Employee

result = session.query(

employee_tbl.employee_id,

employee_tbl.name

).outerjoin(

employee_tbl.payroll_payment

).all()

最近、こちらのSQLAlchemyでシンプルにjoinするという記事も書きました。

最後までお読みいただきましてありがとうございました！

【PR】「AWS認定試験対策 AWS クラウドプラクティショナー」という本を書きました。

【PR】「AWSではじめるLinux入門ガイド」という本を書きました。

【PR】「ポケットスタディ AWS認定デベロッパー - アソシエイト」という本を書きました。

開発ベンダー5年、ユーザ企業システム部門通算9年、ITインストラクター3年目でプロトタイプビルダーもやりだしたSoftware Engineerです。
質問はコメントかSNSなどからお気軽にどうぞ。
出来る限りなるべく答えます。

このブログの内容/発言の一切は個人の見解であり、所属する組織とは関係ありません。
このブログは経験したことなどの共有を目的としており、手順や結果などを保証するものではありません。
ご参考にされる際は、読者様自身のご判断にてご対応をお願いいたします。

また、勉強会やイベントのレポートは自分が気になったことをメモしたり、聞いて思ったことを書いていますので、登壇者の意見や発表内容ではありません。

- Python MySQL, python, sql

Tweet

関連記事

: Linux Mint 17 MATE 64bit にTensorFlowをインストールする

勉強会でTensorFlowを使用しますので、Linux Mint 17 MAT …

: SendGrid(sendgrid_python)でメール送信してイベントの情報からメール本文をたどれるようにしておく

動的に生成するメールで実際にどんな本文が送信されたかを記録しておきたいときもある …

: Redmine REST APIを操作するpython_redmineを試してみた

Redmine のGUIの登録が面倒なのでコマンドで登録、更新、時間の記録が出来 …

: 「神戸Pythonの会 #2 meetup」に行ってきました

「神戸Pythonの会 #2 meetup」に行ってきました。所感など Ato …

: 「大阪Pythonユーザの集まり」に行ってきました

「大阪Pythonユーザの集まり」に行ってきました。あんまりメモ取れてません …

: PythonでHTMLエスケープされた全角ハイフンをアンエスケープする

PythonでHTMLエスケープとアンエスケープについて調べていると、 xml. …

: CentOS 6にPython実行環境を構築

CentOS6(32bit)にPython2.7実行環境を構築した際のメモです。 …

: Pepper 開発ワークショップ初級~中級~番外編に1日で一気に参加した

Pepperの開発方法が知りたかったので、Pepperアトリエ秋葉原 with …

: 「MonotaRo Tech #3 テスト自動化」に行ってきました

モノタロウさんの「MonotaRo Tech #3 テスト自動化」に行ってきまし …

: feedlyでタグ付けした記事を自動でメール配信する

feedlyを使っていて、良記事や知っておいて欲しい記事とかを部門とかチームとか …

PREV: ION Audio Vinyl Motion レコードプレイヤーでアナログ音源をiTunesにインポート
NEXT: SQLAlchemyのModelクラスをMySQLから自動生成する

NEW POST

: 食べログの「ブログに店舗情報を貼る」便利ですね

もうひとつ書いてるブログがありまして、主に自転車の走行記録を書いてたのですが、最 …

: iPad ProのWorking CopyでAWS CodeCommitのリポジトリを使う

iPad Proを導入しましたので、原稿執筆や校正でフル活用しようと思いまして。 …

: Apple Silicon M1 MacBook ProにAmazon Chimeをインストールしました

ChromeブラウザでAmazon Chimeに参加(音が聞こえない) 勉強会に …

: Apple Silicon M1 MacBook ProにHomebrewをインストールしてみる

環境 MacBook Pro (13-inch, M1, 2020)のmacOS …

: Media-JAWS【第8回】「AWS人材教育について語る！」に参加しました。

Media-JAWS【第8回】「AWS人材教育について語る！」に参加しました。 …

配信ライブカレンダー

[PR] AWS認定試験対策 AWS クラウドプラクティショナー

[PR] AWSではじめるLinux入門ガイド

[PR] ポケットスタディ AWS認定デベロッパー – アソシエイト

タグ
alexa alexaday2018 alexaday2019 api apigateway AWS CentOS cloudwatch devsumi2018 dynamodb EC2 gas git google iam iot iphone Java jaws kintone lambda Linux mac mac-mini Markdown mint MySQL Nginx oracle Pandoc PHP python RDS re:dash Redmine remote rocketchat s3 seminor Silver Twilio windows WordPress yamamugi 勉強会

アーカイブ
アーカイブ

AMAZONアソシエイト

「Amazon.co.jpアソシエイト」または「ヤマムギ」は、Amazon.co.jpを宣伝しリンクすることによってサイトが紹介料を獲得できる手段を提供することを目的に設定されたアフィリエイトプログラムである、Amazonアソシエイト・プログラムの参加者です。