Pythonで結果を使ってmysqlデータベースを更新する

Question

私はPythonの初心者ですので、構文も間違っている可能性があります。私はバルク私のSQLデータベースを更新したい。私はすでにNULL値でデータベースに列を作成しています。私の目標は、Python上で移動平均を見つけ、その値を使ってデータベースを更新することです。しかし、問題は、私が見つけた移動平均は、列が時間ブロックで行が日付であるデータテーブル形式にあるということです。しかし、データベースでは、日付と時刻の両方のブロックが異なる列になります。

MA30 = pd.rolling_mean(df, 30) 

cur.execute(""" UPDATE feeder_ndmc_copy 
      SET time_block = CASE date, (MA30)""") 

db.commit() 

これはエラーです。

self.errorhandler(self, exc, value) 

私は他の多くの質問回答を見ましたが、pythonコマンドの発見を使ってデータベースを更新する方法の例はありません。助言がありますか？

Answer 1

[OK]をクリックすると、質問に含まれる情報がまったくなくても完全な回答が得られませんが、どうすればこの問題に対処できるか説明していきます。

おそらく最も簡単な方法は、更新する行ごとに個別のUPDATEクエリを自動的に書き込むことです。私が誤解していないなら、これはデータベース側では比較的効率的ですが、Pythonプログラムではオーバーヘッドが発生します。私はデータベースの人ではありませんが、あなたの質問ではパフォーマンスの最適性について言及していないので、私は今のところうまくいくソリューションがあればいいと思います。

データベースとのやりとりを処理するためにsqlalchemyを使用します。コードをコピーしたい場合は、sqlalchemyをインストールして、コードにモジュールをインポートする必要があります。

まず、sqlalchemyエンジンを作成する必要があります。私はローカルデータベースを使用していると仮定します。そうでなければ、この部分を編集する必要があります。

engine = sqlalchemy.create_engine('mysql://localhost/yourdatabase') 

は今、私も何もあなたの時間の形式を知っていますか私は更新したい列の名前がわからないので、私はプレースホルダを使用します（すべての私たちのクエリを含む文字列を作成することができますありませんインデックス、私は推測する必要があります）：

queries = '' 
for index, value in MA30.iterrows(): 
    queries += 'UPDATE feeder_ndmc_copy SET column_name = {} WHERE index_column_name = {};\n'.format(value, index.strftime(%Y-%m-%d %H:%M:%S)) 

あなたの要件に合わせてこの部分を大きく調整する必要があります。私はあなたのデータベースの適切なスキーマを提供しなければ、それ以上のことはできません。完全なクエリのリストで

、我々はSQLにデータを入れて進みます

with engine.connect() as connection: 
    with engine.begin(): 
     connection.execute(queries) 

編集：

明らかに私の解決策は、あなたのパンダの場合のようなものをどのような方法で対処していませんmysqlにないタイムスタンプのデータポイントを作成する操作などがあります。そのことを覚えておく必要があります。それが問題であれば、フォームのクエリを使用する必要があります

INSERT INTO table (id,Col1,Col2) VALUES (1,1,1),(2,2,3),(3,9,3),(4,10,12) 
ON DUPLICATE KEY UPDATE Col1=VALUES(Col1),Col2=VALUES(Col2);