【mysql+php】CSVファイルのインサートについて

Question

CSVファイルのインサートについて
PHPでCSVファイルのインサートを考えています。

下記は接続、インサートが可能でした。

<?php
$mysqli = new mysqli('localhost', 'root', '1234', 'database');
/* 接続状況をチェックします */
if (mysqli_connect_errno()) {
    printf("Connect failed: %s\n", mysqli_connect_error());
    exit();
}

$stmt = $mysqli->prepare("INSERT INTO test VALUES (?, ?, ?)");
$stmt->bind_param('sss', $div, $no, $sub);
$div = '1';
$no = '2';
$sub = "3";
/* プリペアドステートメントを実行します */
$stmt->execute();
printf("%d Row inserted.\n", $stmt->affected_rows);
/* ステートメントと接続を閉じます */
$stmt->close();
?>

上記の結果は、
1 Row inserted.
となり、ちゃんとインサート出来ていました。

しかし、今回はCSVファイルのインサートになるため、
$div = '1';
$no = '2';
$sub = "3";
のように分かれてはいません。

CSVファイルのように纏まったデータを分解してインサートするテストとして下記のように、$H='4,5,6';を組んでみました。

<?php
$mysqli = new mysqli('localhost', 'root', '1234', 'database');
/* 接続状況をチェックします */
if (mysqli_connect_errno()) {
    printf("Connect failed: %s\n", mysqli_connect_error());
    exit();
}
$stmt = $mysqli->prepare("INSERT INTO test VALUES (?, ?, ?)");
$stmt->bind_param('sss', $H['0'], $H['1'], $H['2']);
$H='4,5,6';
/* プリペアドステートメントを実行します */
$stmt->execute();
printf("%d Row inserted.\n", $stmt->affected_rows);
/* ステートメントと接続を閉じます */
$stmt->close();
?>

結果
-1 Row inserted.
という表示がされ、実際にはインサート出来ていません。

どこが間違っているのでしょうか?

今回、PHP7に移行したため、mysql関数を離れ、初めてPDOを使っています。
初歩的なことかと思いますが、よろしくお願いいたします。

Answer 1

問題は以下の部分にあります。

$stmt = $mysqli->prepare("INSERT INTO test VALUES (?, ?, ?)");
$stmt->bind_param('sss', $H['0'], $H['1'], $H['2']);
$H='4,5,6';

$stmt->bind_paramの部分で、$Hは普通の文字列なのに4,5,6などの各要素を配列のように
取得しようといています。

ですので以下のように一度配列に格納してから使用した方がいいでしょう。
※通常の配列の場合は$H[0]とアクセスします。$H['0']だと連想配列です。

$stmt = $mysqli->prepare("INSERT INTO test VALUES (?, ?, ?)");
$stmt->bind_param('sss', $H[0], $H[1], $H[2]);
$line='4,5,6';
$H=explode(',', $line);

Comments

[tajix_japan]

有難うございます。

<?php
$mysqli = new mysqli('localhost', 'root', '1234', 'database');
/* 接続状況をチェックします */
if (mysqli_connect_errno()) {
printf("Connect failed: %s\n", mysqli_connect_error());
exit();
}

$stmt = $mysqli->prepare("INSERT INTO test VALUES (?, ?, ?)");
$stmt->bind_param('sss', $H[0], $H[1], $H[2]);
$line='4,5,6';
$H=explode(',', $line);

/* プリペアドステートメントを実行します */
$stmt->execute();

printf("%d Row inserted.\n", $stmt->affected_rows);

/* ステートメントと接続を閉じます */
$stmt->close();
?>

としてみましたが、うまくインサート出来ていません。
-1 Row inserted.
の表示のままです。
まだおかしいところがあるのでしょうか?
よろしくお願いいたします。

[wattaru]

試しに以下のように修正できますでしょうか。bind_param関数では配列を使用できるようです。
-------------------------------------------
$H = array();
$stmt->bind_param('sss', $H);
$line='4,5,6';
$H=explode(',', $line);

[tajix_japan]

有難うございます。
以下に修正して試してみました。
<?php
$mysqli = new mysqli('localhost', 'root', '1234', 'database');
/* 接続状況をチェックします */
if (mysqli_connect_errno()) {
printf("Connect failed: %s\n", mysqli_connect_error());
exit();
}

$stmt = $mysqli->prepare("INSERT INTO test VALUES (?, ?, ?)");
$H = array();
$stmt->bind_param('sss', $H);
$line='4,5,6';
$H=explode(',', $line);

/* プリペアドステートメントを実行します */
$stmt->execute();

printf("%d Row inserted.\n", $stmt->affected_rows);

/* ステートメントと接続を閉じます */
$stmt->close();
?>

こんどは、
Warning: mysqli_stmt::bind_param(): Number of elements in type definition string doesn't match number of bind variables in
というエラーが出てしまいました。
-1 Row inserted.
ということで、インサートもされていません。

何度も申し訳ございません。
もし何かアドバイスがあればよろしくお願い申し上げます。

[wattaru]

エラー内容としては型定義文字列の要素数が、バインド変数の数と一致していないと言ってますね。
一度var_dumpなどで$Hにどのような内容が格納されているか確認できますでしょうか。

[tajix_japan]

有難うございます。何度も申し訳ありません。
下記のように取れているようです。3つで数量もあっています。
array(3) { [0]=> string(1) "4" [1]=> string(1) "5" [2]=> string(1) "6" }
$Hをあくまでひとつとして計算しているのでしょうか?

[tajix_japan]

下記で出来ました!!
ヒントを頂きましてありがとうございました。
深く御礼申し上げます。

<?php
$mysqli = new mysqli('localhost', 'root', '1234', 'database');
/* 接続状況をチェックします */
if (mysqli_connect_errno()) {
printf("Connect failed: %s\n", mysqli_connect_error());
exit();
}

$stmt = $mysqli->prepare("INSERT INTO test VALUES (?, ?, ?)");
$stmt->bind_param('sss', $div, $no, $sub);
$line='4,5,6';
$H=explode(',', $line);
$div = $H[0];
$no = $H[1];
$sub = $H[2];
/* プリペアドステートメントを実行します */
$stmt->execute();

printf("%d Row inserted.\n", $stmt->affected_rows);

/* ステートメントと接続を閉じます */
$stmt->close();
?>

[wattaru]

よかったです!