sqlalchemy に基づいて MySQL で追加、削除、変更、クエリ操作を実装する

sqlalchemy からインポート、存在する、列、整数、文字列、外部キー、存在する
sqlalchemy.ext.declarative から declarative_base をインポートします
sqlalchemyからcreate_engineをインポート
sqlalchemy.ormからsessionmakerをインポート

# データベースエンジンを作成しました engine = create_engine("mysql+pymysql://user:pwd@ip/database name?charset=utf8")

#セッションタイプを作成 DBSession = sessionmaker(bind=engine)

# 公式モデルをインスタンス化します - Base は ORM モデルです Base = declarative_base()


# サービス注文テーブルを作成する class ServiceOrder(Base):
  __tablename__ = 'サービスオーダーテーブル'
  id = 列(整数、主キー=True、自動増分=True)
  serviceOrderId = Column(String(32), nullable=False, index=True, comment='サービス注文ID')
  serviceDesc = Column(String(268), comment='サービスの説明')
  oneLevelName = 列(文字列(32)、コメント='C カテゴリ')
  twoLevelName = Column(String(32), コメント='T サブクラス')
  threeLevelName = Column(String(32), comment='I プロジェクト')
  fourLevelName = Column(String(32), comment='S サブ項目')
  transferTimes = Column(String(32), comment='転送回数')
  overDueStatus = Column(String(32), comment='期限切れステータス')
  serviceTimeLimit = Column(String(32), comment='サービス時間制限')
  serTimeLimitTypeName = Column(String(16), comment='時間制限タイプ')  
  # 1対多:
  # serviceWorkOrder = relationship("ServiceWorkOrder", backref="serviceorder")


# 多対一: 複数のサービス オーダーがサービス オーダー クラス ServiceWorkOrder(Base) に属することができます。
  __tablename__ = 'サービス作業注文テーブル'
  id = 列(整数、主キー=True、自動増分=True)
  serviceWorkOrderId = Column(String(32), nullable=False, index=True, comment='サービス作業注文ID')
  workOrderName = Column(String(268), comment='作業指示書名')
  fromId = Column(String(32), comment='サービス注文ID')
  createUserSectionName = Column(String(32), comment='ユーザーセクションの作成')
  createUserName = 列(文字列(32)、コメント='作成者')
  handlerName = Column(String(32), comment='Handler')
  statusName = Column(String(32), comment='作業指示書のステータス')
  createTime = Column(String(32), comment='作成時刻') 
  # 「多」側の book テーブルは、外部キーを介して user テーブルにリンクされています。
  # serviceOrder_id = 列(整数、外部キー('serviceOrderTable.id'))

# データベースを作成します。データベースがすでに存在する場合は作成されません。ライブラリ名に従って既存のライブラリに直接接続します。def init_db():
  Base.metadata.create_all(エンジン)

drop_db() を定義します:
  Base.metadata.drop_all(エンジン)

デフ挿入更新():
  # all_needed_data_lists は、データベースに挿入する必要があるデータ形式です [{key: value, ... }, { }, { }...]
  all_needed_data_lists 内の項目の場合:
    ServiceOrderRow = ServiceOrder(serviceOrderId=item['serviceOrderId'],
                    サービス説明=item['サービス説明'],
                    ワンレベル名=アイテム['ワンレベル名'],
                    twoLevelName=アイテム['twoLevelName'],
                    threeLevelName=アイテム['threeLevelName'],
                    fourLevelName=アイテム['fourLevelName'],
                    転送時間=item['転送時間'],
                    期限超過ステータス=item['期限超過ステータス'],
                    サービス時間制限=item['サービス時間制限'],
                    serTimeLimitTypeName=item['serTimeLimitTypeName'],
                    ）
    試す：
      # exists を使用して、ターゲットオブジェクトが存在するかどうかを判断し、True または Faults を返します。
      it_exists = セッション.クエリ(
          存在する()。ServiceOrder.serviceOrderId == item['serviceOrderId'] )
        ）。スカラー（）
    except 例外を e として:
      自己ログエラー(e)
      壊す
    試す：
      # 存在しない場合は追加します。存在する場合は、既存のデータを更新します。存在しない場合は it_exists:
        セッション.add(サービスオーダー行)
      それ以外：
        session.query(ServiceOrder).filter(ServiceOrder.serviceOrderId == item['serviceOrderId'])\
          .update(アイテム)
    except 例外を e として:
      自己ログエラー(e)
      壊す
  試す：
    セッションコミット()
    self.log.info('データが正常に更新されました!')
  を除外する：
    セッション.ロールバック()
    self.log.info('データの更新に失敗しました!')

__name__ == "__main__" の場合:
  # データベースを作成します。データベースがすでに存在する場合は作成されません。ライブラリ名に従って既存のライブラリに直接接続します。init_db()
  # 追加、削除、変更、クエリを実行するためのセッション オブジェクトを作成します。
  セッション = DBSession()
  # セッションを使用してデータを追加または変更します。 insert_update() を送信することを忘れないでください。