PHPからMySQLへの連想配列INSERT

Question

連日の質問失礼いたします。

Pythonで作成したJSON配列をPOST通信でPHPへ送信、
PHPでJSON配列をデコードし、取り出した連想配列をMySQLへINSERTしたく思い、
下記コードを作成致しました。

import csv
import requests
import json
import hashlib
import hmac
import base64

# リクエスト先PHP
API_Endpoint = 'http://localhost:8888/------/logs_insert.php'


body = {
    "data" : [
        {
            'user_id': '0001',
            'ins_id': 'green_green_greeeeen',
            'ha_tag': '国分寺',
            'tar_id': 'cobo.cobo.sucrier',
            'li_at': '2021-05-11 00:25:46',
            'pos_at': '2021-05-10T15:17:03.000Z'
        },
        {
            'user_id': 'AAAAA',
            'ins_id': 'green_green_greeeeen',
            'ha_tag': '国分寺',
            'tar_id': 'kimagure_took',
            'li_at': '2021-05-11 00:26:04',
            'pos_at': '2021-05-10T14:53:51.000Z'
        },
        {
            'user_id': 'AAAAA',
            'ins_id': 'green_green_greeeeen',
            'ha_tag': '国分寺',
            'tar_id': 'm710ys',
            'li_at': '2021-05-11 00:26:19',
            'pos_at': '2021-05-10T14:47:33.000Z'
        }
        ]
    }

json_body = json.dumps(body)
custom_header = {'Content-Type': 'application/x-www-form-urlencoded',
                'X-Signature' : xxxxxxxx}

# API接続
result = requests.post(API_Endpoint,data=json_body,headers=custom_header)
print( "status:", result.status_code )

print(result)
print(result.text)

↓Pythonから受け取るPHPです。

<?php
require_once('function.php');
$dbh = dbConnect();

$logs = json_decode(file_get_contents('php://input'),true);

foreach($logs as $log){
    foreach($log as $values){
        foreach($values as $value){
            try {
                $stmt = $dbh->prepare("INSERT INTO like_logs(user_id,ins_id,ha_tag,tar_id,li_at,pos_at) values (?,?,?,?,?,?)");
                $stmt->execute($value);
                $dbh->commit();
                echo '送信成功';

            } catch(PDOException $e){
                echo '送信失敗'. $e->getMessage();
                exit();  
            };
        }
    }
}
?>

下記エラー文が出ます。

There is no active transaction

MySQLのテーブル情報は以下です。
①id int(191) AUTO_INCREMENT
②user_id varchar(191)
③ins_id varchar(191)
④ha_tag varchar(191)
⑤tar_id varchar(191)
⑥li_at datetime(6)
⑦pos_at datetime(6)
⑧created_at timestamp(6)

$valueをvar_dampしてみてデータの数を数えても、SQL命令文内のデータの数と一致しているのにエラーが出ます。
他にコード内で悪い箇所があるのでしょうか。

宜しくお願い致します。

Answer 1

プレースホルダの使い方をきちんと学ぶ必要がある、のは当然として……

            $stmt = $dbh->prepare("INSERT INTO logs(user_id,ins_id,ha_tag,tar_id,li_at,pos_at) values (?,?,?,?,?,?)");

ここでプレースホルダありの SQL 文を準備しています。

            $stmt->execute($value);

この文が誤っています。
executeをする際には、プレースホルダの全てに値をバインドしておかなくてはなりません。もとの SQL ではプレースホルダが6個ありますので、6つの値をバインドしなくてはいけません。

Comments

[Yt182]

Foreachの中でもう一度Forearchすることによりエラーを回避できました。
が、MySQLへお目当ての項目がINSERTされておりませんでした。
エラーも出ていないので、何がおかしいかが不明です。データベースへの接続も問題なく行われていました。

[tacsheaven]

オートコミットでない場合は execute() した後に commit() しなくては結果が反映されません。
また、insert の SQL が成功したかどうか、execute() の戻り値をチェックするなどしましょう。

[Yt182]

ありがとうございます。
試してみましたが、There is no active transactionとエラー文が出てしまいます。

また、戻り値のチェックはどうやって行うのでしょうか。

度々すみません。
宜しくお願い致します。