phpのエラーについて

Question

phpからmysqlへのinsertでエラーが出て困っております。
LOAD DATA LOCAL INFILEをしたいのですが、

Fatal error: Call to a member function query() on null in /var/www/html/php/IN_DATA_test2.php on line 16

のエラーが解決できません。
$stmt = $dbh->prepare($sql);時点で、dbhの持つ値に問題があるということなのでしょうか。

現在、フォームからの値の入力はできているためドライバ関連のエラーはなく、
sql文単体では問題なく動作していることを確認済みです。

どなたか、お知恵を貸していただけないでしょうか。

<?php try{ $dbh = new PDO('mysql:dbname=GPS;host=tk2-218-18679.vs.sakura.ne.jp', 'root', array(PDO::MYSQL_ATTR_LOCAL_INFILE => true)); print('<br>'); if ($dbh == null){ print('接続に失敗しました。<br>'); }else{ print('接続に成功しました。<br>'); } $dbh->query('SET NAMES utf8'); $sql = 'LOAD DATA LOCAL INFILE "/GPS_log.csv" INTO TABLE test FIELDS TERMINATED BY "," LINES TERMINATED BY "\n";'; $stmt = $dbh->prepare($sql); $stmt->execute(); }catch (PDOException $e){ print('Error:'.$e->getMessage()); die(); } $dbh = null; ?>

Comments

[退会済みユーザー]

「on line 16」の１６行目にあるセンテンスは何でしょうか？

[aine]

下記が16行目です。
$sql = 'LOAD DATA LOCAL INFILE "/GPS_log.csv" INTO TABLE test FIELDS TERMINATED BY "," LINES TERMINATED BY "\n";';

Answer 1

エラーそのものは、16行目のPDO::queryメソッドで発生しています。

$dbh->query('SET NAMES utf8');

しかし、問題の本質はこの部分では無いようです。

まず、PDOの使い方が誤っています。
例示されたコードで、PDOの初期化を行っている箇所を見やすく改行すると、以下のようになります。
(以降のコードでは安全のため、ホスト名をexample.comに置き換えています)

$dbh = new PDO(
	'mysql:dbname=GPS;host=example.com',
	'root',
	array(PDO::MYSQL_ATTR_LOCAL_INFILE => true)
);

第一引数にDSN(mysql:dbname=GPS;host=example.com)、第二引数にusername(root)を指定しているところまでは問題ありませんが、第三引数にはpasswordの文字列を指定します。
しかしこのコードでは、第四引数に指定するはずのoptionsを第三引数に指定してしまっています。

PHP: PDO::__construct - Manual

簡単にいえば、パスワードの指定忘れです。これがこのコードがエラーとなる直接の原因です。

また別の問題として、エラー処理が不適切という点も挙げられるでしょう。
10～14行目で、PDOの初期化に失敗した場合にエラーメッセージが表示されるようになっていますが、「接続に失敗しました。」と表示した後も処理を続けています。

if ($dbh == null){
	print('接続に失敗しました。<br>');
}else{
	print('接続に成功しました。<br>');
}

正しく実装するならば、「接続に失敗しました。」と表示した時点で例外を投げるなりして処理を終了するべきでしょう。

私ならば以下のように書きます。

<?php

try{
	/**
	 * PDOのコンストラクタに指定する引数を正しく指定。
	 * また文字セットのutf8は、DSNで指定する。
	 * (文字セットをDSNで指定するやり方は、PHP5.3.5以前ではできません)
	 */
	$dbh = new PDO(
		'mysql:dbname=GPS;host=example.com;charset=utf8',
		'root',
		'password',
		array(
			// 発生したエラーが例外としてスローされるよう指定
			PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
			PDO::MYSQL_ATTR_LOCAL_INFILE => true,
		)
	);

	/**
	 * PDOへの接続に失敗した場合、エラーを例外としてスロー(投げる)
	 */
	if (!$dbh) {
		throw new RuntimeException('接続に失敗しました。');
	}

	echo '接続に成功しました。';

	$sql = 'LOAD DATA LOCAL INFILE "/GPS_log.csv" INTO TABLE test FIELDS TERMINATED BY "," LINES TERMINATED BY "\n";';
	// ユーザ入力を伴わず、また結果を必要としていないため、PDO::execメソッドを使用
	$dbh->exec($sql);
} catch (PDOException $e) {
	/**
	 * PDOで発生した例外の処理
	 */
	echo 'PDO Error: ' . $e->getMessage();
} catch (Exception $e) {
	/**
	 * PDO以外で発生した例外の処理
	 */
	echo 'Error: ' . $e->getMessage();
}

参考:

• PHPでデータベースに接続するときのまとめ - Qiita
• PHPでCSVファイルをUTF8に変換したい - PHP | 【OKWave】

Comments

[sounisi5011]

解答そのものからはズレますが、ホスト名を直接記載するのは危険です。
ホスト名だけでも、質問のコードがどこのサーバのMySQLに接続しようとしているのかおおよその検討がついてしまいます。
私の解答のように、ホスト名を別のものに置き換えたほうが良いでしょう…
(example.comは例示用に確保されているものなので、安全です)

[aine]

ありがとうございます。無事insertでき、解決しました。

[aine]

ホスト名についてもありがとうございます。書き換えます。

Answer 2

pdoが接続に失敗しています。
そのため、$dbhがnullとなり、nullに対してquery()というメンバ関数を呼ぼうとしています。

Comments

[aine]

確認した所、おっしゃるとおり、接続失敗のエラーがありました。

下記コードでは接続成功でしたが・・・arrayをつけたことで、書き方を変えたのがいけなかったでしょうか。

$dsn = 'mysql:dbname=men;host=tk2-218-18679.vs.sakura.ne.jp';
$user = 'root';
$password = '';

try{
$dbh = new PDO($dsn, $user, $password);

可能であれば、正しい書き方を教えていただけませんか。

[orange0190]

sounisi5011さんの回答を参考にしてください。