【Python3】SQLAlchemyを使用し、UpdateとInsertを（1トランザクションで）行いたい

Question

実現したいこと

SQLAlchemyを使用して、UpdateとInsertを1トランザクションで行いたいです。

詳細：
入力画面上で、"ID"と"str"が入力出来る画面があります。
"ID"が登録あった場合、入力[ID]の"end"を現在時刻に更新、更新した"ID"と入力された"str"を登録（insert）したいです。
※もはや、何をどうしたらいいのかわからなくなりました。insertとupdateがよくわかっていないのかもしれません・・・すみません。

実現したいDB

（もともとのDB(con)の状態）
|id|str|start 　 　　 | 　　end
|:--|:--:|--:|
|1|aaa|2019-08-22 23:27:13|9999-12-31 09:00:00

上記DBが、下記のように更新されるイメージ。（↓）
teime_endを現在日時に更新して、同じidで登録する。（strが入力画面から受け取った内容）
|id|str|start | end　　　　　　　　
|:--|:--:|--:|
|1|aaa|2019-08-26 23:27:13|2019-08-28 23:27:13(現在日時に更新(now()))
|1|bbb|2019-08-26 23:27:13|9999-12-31 09:00:00(☆ここが追加（insert）)

※プライマリーキーのことは、忘れてください。

現状

下に、途中コードを載せますがここから先どうしたらいいのかで止まっています。
現在"name 'm_data' is not defined"エラーで止まっている状態です。
（自身で解決できれば、すぐにコードを更新致します。申し訳ありません。）

作成中のコード

b.py

class Con:
　　def put_main(self, id):
       # Update
       update = Con.query.filter(id == id).first()
       update.end = datetime.datetime.now()
       if update is None:
          print('NotUpdate')
       else:
　　　　　　# updateaあったらinsert
          data = []
          # insert
          insert = Con(
            id   = data['id'],
            str  = data['str'],
            start= created_time,
            end  = datetime.date.max,
          )
        m_set.append(insert)
        contact = Contact(**data)
        m_set.append(contact)
        self.__commit(update, insert)
        return m_set

現在以下のURL参考に進めています。

SQLAlchemyでUpdateするには
SQLAlchemyの基本的な使い方
SQLAlchemyで基本的なSQLクエリまとめ
など...

こんな感じでやれば出来るのではないかなどのアドバイスだけでも頂ければ幸いです。
updateとinsertしたいです・・・よろしくお願い致します。

Answer 1

混乱して意味がわからなくなり困ったので、updateとinsert分けました。
１トランザクションでの話は、再度調査し直しいたします。
このような形になり、申し訳ないです。。

    def update(self, update_data):
        update_data.valid_time_end = datetime.datetime.now()
        self.__commit(update_data)

    def insert(self, id, date):
        # insert
        insert = Table(
            id   = data['id'],
            str  = data['str'],
            start= created_time,
            end  = datetime.date.max,
        )
        self.__commit(insert)

Answer 2

今ひとつやりたいことがわからないのですが、Sessionを使ってトランザクション管理をするだけでは駄目なのでしょうか？？

from sqlalchemy import create_engine
from sqlalchemy import extract
from sqlalchemy import Column, Integer, String, DATETIME
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker
from datetime import datetime
import time

engine = create_engine('sqlite:///:memory:', echo=True)
base = declarative_base()

class Con(base):

    def __init__(self, name):
        self.str = name
        self.start = datetime.now()
        self.end = datetime.now()        

    __tablename__ = 'con'

    id = Column(Integer(),
                nullable=False,
                primary_key=True,
                autoincrement=True,
                unique=True,
                comment="ID")
    str = Column(String(128), nullable=False)
    start = Column(DATETIME, nullable=False)
    end = Column(DATETIME, nullable=False)    

base.metadata.create_all(engine)

Session = sessionmaker(bind=engine)
session = Session()

# とりあえず最初の状態を作る
session.add(Con('aaa'))
session.add(Con('bbb'))
session.commit()

time.sleep(3)

# ここから以下を１トランザクションで行いたい
print("-----")
session.add(Con('ccc')) # データを追加
session.query(Con).update({'end':datetime.now()}) # 全データの'end'を更新
session.commit()
print("-----")

# 一応結果表示
for c in session.query(Con).all():
    print(f'{c.id}, {c.str}, {c.start} {c.end}')

Comments

[s_akira]

言葉足らず、わかりずらく申し訳ありません。
"既存データ更新"と"更新されたidと画面入力値のinsert"をしたいだけなのです…うまく言えなくて申し訳ありません。
自身も混乱しているため、今一度質問を読み直しと修正行いたいと思います。

トランザクション管理のコードを貼ってくださりありがとうございます。
参考にさせていただきます。ご回答ありがとうございます。

[magichan]

私のサンプルコードにて、質問の「実現したいDB」 をほぼ実現できてると思うのですが、まだなにか足りないでしょうか？

[s_akira]

サンプルコードを参考にしようと思ったのですが、うまく動作ができませんでした。
また、理解がおよびませんでした・・・申し訳ありません。
改め、勉強し直します。
ご回答いただいたのに、私の理解が及ばず大変申し訳ありません。
ご回答頂きありがとうございました。