PHPのPDO接続でレコードをDELETE出来ない

Question

前置き

Wordpressの便利な部分を活用しつつ一つのDBでは不可能/難しい/面倒臭い（と思う）複雑（だと思う）な複数DBシステムを構築し、そちらを外部PHPで操作する、といったことをやっています。

やりたいこと

コース内のプランこと、レコードを消去するSQL文を実行したいです。
コース=テーブル
プラン=レコード
という感じです。

発生している問題

下の実験1はSHOW TABLESでしっかりテーブルの一覧が表示されるので、データベースに接続できてはいるのですが、
上のレコードを消去するSQL文が機能してくれません。

var_dumpによると
bool(false)
だそうです。

echo 'プランを消去します';

try{
    $pdo = new PDO("mysql:dbname=$db_datebase_6;host=$db_address_3;charset=utf8",$db_user,$db_password);
    $stmt = $pdo->query('DELETE FROM consumercourse WHERE planid=test');
    echo '<br>';
    var_dump($stmt);
}catch(PDOException $e){
    echo 'Connection failed: ' . $e->getMessage();
    var_dump($e);
    echo 'エラーが発生しました。';
}


//実験1⇓
if (isset($db_address_3) && isset($db_datebase_6) && isset($db_user) && isset($db_password)) {
try{
    $pdo = new PDO("mysql:dbname=$db_datebase_6;host=$db_address_3;charset=utf8",$db_user,$db_password);
    foreach($pdo->query('SHOW TABLES') as $row) {
        print_r($row);
    }
}catch(PDOException $e){
    echo 'Connection failed: ' . $e->getMessage();
    var_dump($e);
    echo 'エラーが発生しました。';
}
} else {
    echo 'データが格納されていません';
}

証拠画像

![
PHPMyAdminによるとこのようになっています。
testの行が消去されるはずなんですが…

環境

• ロリポップ
• MYSQL
• Wordpress

＋の質問

回答者様によってレコードの消去方法が判明しましたが、次はちょっと別のトラブルが発生しました。

やりたい事

SQL文への変数代入方法が知りたいです。

echo 'プランを消去します';
//コース＝テーブルの取得
$select = $_GET['courseselect'];
//レコード＝プランの取得
$planid = $_GET['p_delete'];

echo '<br>';
echo "$select";
echo '<br>';
echo "$planid";
//しっかり取得できてはいる↑

try{
    $pdo = new PDO("mysql:dbname=$db_datebase_6;host=$db_address_3;charset=utf8",$db_user,$db_password, [PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION]);
    //テーブル（コース）とレコード（プラン）の変数をSQL文に代入したい↓
    $stmt = $pdo->query("DELETE FROM ' . $select . ' WHERE planid='' . $planid . ''");
    //foreach($pdo->query('DELETE FROM consumercourse WHERE planid=test') as $row) {
    echo '<br>';
    var_dump($stmt);
    //}
}catch(PDOException $e){
    //ここで補足される例外はコネクションだけではない
    //
    echo 'Connection failed: ' . $e->getMessage();
    var_dump($e);
    echo 'エラーが発生しました。';
}

echo '<br>';

if (isset($db_address_3) && isset($db_datebase_6) && isset($db_user) && isset($db_password)) {
try{
    $pdo = new PDO("mysql:dbname=$db_datebase_6;host=$db_address_3;charset=utf8",$db_user,$db_password);
    foreach($pdo->query('SHOW TABLES') as $row) {
        print_r($row);
        echo '<br>';
        var_dump($row);
    }
}catch(PDOException $e){
    //ここで補足される例外はコネクションだけではない
    //echo 'Connection failed: ' . $e->getMessage();
    var_dump($e);
    echo 'エラーが発生しました。';
}
} else {
    echo 'データが格納されていません';
}

こちらが↑のファイルの上位にあるファイルです

$select = $_GET['courseselect'];
$db_address_1 = 'hogehoge.phy.lolipop.lan';
$db_address_2 = 'hogehoge.phy.lolipop.lan';
$db_address_3 = 'hogehoge.phy.lolipop.lan';

$db_user = 'hogehogehoge';
$db_password = 'hogehogehoge';

$db_datebase_1 = 'hogehoge-hogehogehoge';
$db_datebase_2 = 'hogehoge-hogehogehoge';
$db_datebase_3 = 'hogehoge-hogehogehoge';
$db_datebase_4 = 'hogehoge-hogehogehoge';
$db_datebase_5 = 'hogehoge-hogehogehoge';
$db_datebase_6 = 'hogehoge-hogehogehoge';

//接続方法が原始的なのはお許しください
$conn = mysql_connect($db_address_3, $db_user, $db_password);

if (!$conn) {
    echo "データベースに接続できません: " . mysql_error();
    exit;
}

if (!mysql_select_db($db_datebase_6)) {
    echo "データベースを選択できません: " . mysql_error();
    exit;
}
$result = mysql_query('SET NAMES utf8', $conn);
$sql = "SELECT 	planid, planname, plandescription, initialfee, monthlycost, video, consultation
        FROM   $select";

$result = mysql_query($sql);

if (!$result) {
    echo "データベース/テーブルを読み込めません ($sql) from DB: " . mysql_error();
    exit;
}

if (mysql_num_rows($result) == 0) {
    echo "このコースにはまだプランがないようです。";
}

print('<table class="wp-list-table widefat fixed striped pages">');
while ($row = mysql_fetch_assoc($result)) {
    print('<tr>');
    print('<td>');
    print $row["planid"];
    print('</td>');
    print('<td>');
    print $row["planname"];
    print('</td>');
    print('<td>');
    print $row["plandescription"];
    print('</td>');
    print('<td>');
    print $row["initialfee"];
    print('</td>');
    print('<td>');
    print $row["monthlycost"];
    print('</td>');
    print('<td>');
    print $row["video"];
    print('</td>');
    print('<td>');
    print $row["consultation"];
    print('</td>');
    print('<td>');
    $planid = $row["planid"];
    $url = admin_url();
    print '<a href=admin.php?page=hogehoge_system_setting&courseselect=' . $select . '&p_edit=' . $planid . ' ”>プランを編集する</a>';
    print('</td>');
    print('<td>');
    print '<a href=admin.php?page=hogehoge_system_setting&courseselect=' . $select . '&p_delete=' . $planid . ' ”>プランを消去する</a>';
    print('</td>');
    print('</tr>');
}
print('</table>');

$p_edit = $_GET['p_edit'];
$p_delete = $_GET['p_delete'];

mysql_free_result($result);
if (isset($p_edit) or isset($p_delete)) {
    if (isset($p_edit)) {
        require_once ('秘密保守につき割愛/wp-content/themes/ALC/adminpage/sysytemset/plansystem/planedit.php');
        
    }
    if (isset($p_delete)) {
        require ('秘密保守につき割愛/wp-content/themes/ALC/adminpage/sysytemset/plansystem/plandelete.php');
        
    }
} else {
    require_once ('秘密保守につき割愛/wp-content/themes/ALC/adminpage/sysytemset/plansystem/planadd.php');
}

これ↑の更に上位のファイルに、

    $client = $_GET['adminsystempage'];
    if (is_null($client)) {
        
        $db_address_1 = 'hogehoge.phy.lolipop.lan';
        $db_address_2 = 'mysql103.phy.lolipop.lan';
        $db_address_3 = 'mysql132.phy.lolipop.lan';
        
        $db_user = 'hogehoge';
        $db_password = 'hogehoge';
        
        $db_datebase_1 = 'hogehoge-hogehoge';
        $db_datebase_2 = 'hogehoge-hogehoge';
        $db_datebase_3 = 'hogehoge-hogehoge';
        $db_datebase_4 = 'hogehoge-hogehoge';
        $db_datebase_5 = 'hogehoge-hogehoge';
        $db_datebase_6 = 'hogehoge-hogehoge';
        try{
            $pdo = new PDO("mysql:dbname=$db_datebase_6;host=$db_address_3;charset=utf8",$db_user,$db_password);
            $stmt = $pdo->query('SHOW TABLES');
            print('<table class="wp-list-table widefat fixed striped pages">');
            while($a_course = $stmt->fetch(PDO::FETCH_ASSOC)){
                print('<tr>');
                print('<td>');
                $course = $a_course["Tables_in_LAA0547874-familiacours"];
                echo "$course";
                print('</td>');
                print('<td>');
                $title1 = 'コースを編集する';
                $url = admin_url();
                print '<a href="' . $url . 'admin.php?page=familia_system_setting&courseselect=' . $course . '">'.$title1.'</a><br />';
                print('</td>');
                print('<td>');
                $title2 = 'コースを消去する';
                $url = admin_url();
                print '<a href="' . $url . 'admin.php?page=familia_system_setting&coursedelete=' . $course . '">'.$title2.'</a><br />';
                print('</td>');
                print('</tr>');
                echo '<br>';
            }
            print('</table>');
        }catch(PDOException $e){
            //ここで補足される例外はコネクションだけではない
            //echo 'Connection failed: ' . $e->getMessage();
            var_dump($e);
            echo 'エラーが発生しました。';
        }
    }else {
        $coursename = $_POST['coursename'];
        if (is_null($coursename)) {
            echo '
                <form action="" method="POST">
                 <label>コース名</label><br>
                 <input type="text" name="coursename"><br>
        		 <input type="submit" value="コースを追加する" /><br>
                </form
             ';
        }else {
            
            try {
                var_dump($coursename);
        $db_address_1 = 'hogehoge.phy.lolipop.lan';
        $db_address_2 = 'mysql103.phy.lolipop.lan';
        $db_address_3 = 'mysql132.phy.lolipop.lan';
        
        $db_user = 'hogehoge';
        $db_password = 'hogehoge';
        
        $db_datebase_1 = 'hogehoge-hogehoge';
        $db_datebase_2 = 'hogehoge-hogehoge';
        $db_datebase_3 = 'hogehoge-hogehoge';
        $db_datebase_4 = 'hogehoge-hogehoge';
        $db_datebase_5 = 'hogehoge-hogehoge';
        $db_datebase_6 = 'hogehoge-hogehoge';
                
                $conn = new PDO("mysql:host=$db_address_3;dbname=$db_datebase_6", $db_user, $db_password);
                // set the PDO error mode to exception
                $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
                
                // sql to create table
                $sql = "CREATE TABLE $coursename (
                planid TEXT(30),
                planname TEXT(30),
                plandescription TEXT(50),
                initialfee INT(20),
                monthlycost INT(20),
                video INT(20),
                consultation INT(20)
                
                )";
                
                // use exec() because no results are returned
                $conn->exec($sql);
                echo "新規コーステーブルを作成しました。";
            }
            catch(PDOException $e)
            {
                echo $sql . "<br>" . $e->getMessage();
            }
            $conn = null;
        }
    }

とあります

Comments

[m.ts10806]

蒸し返したいわけじゃないんですが、WordPressで導入されたテーブル・データなのであればWordPressの機能による操作が基本なのでは・・。WordPress詳しいわけではないですが、自前で処理をガッツリ組む必要があるようには思えません。

[scrollman]

よく分からずに使っているので曖昧な事しかいえませんが、Wordpressのシステムで使っているDBとは別のデータベースを作成して使っているので、自前で作ったDBに接続して処理するには自前でここまで書かなきゃいけないのかなと思ってこうなりました。WPの中核となるDBと分けて使っているけど要所で併用しているといいますか…。WPの関数に複数のデータベースを選択可能な便利なものがあるのかもしれませんけど。

[m.ts10806]

なるほど。であればその経緯は書かれた方が良いですね。WordPressがタグと環境情報にあるとWordPress配下にあるテーブルに対するアプローチという印象を受けます。何に重きを置くかというところなのでそれで結構回答の方向性が変わってきます。別のテーブルではなく別のDBなのであればむしろWordPressという情報提示は蛇足にも感じます。

[scrollman]

確かにですね。前置きにそこの説明を追記しようと思います。

[退会済みユーザー]

にしてもsqlインジェクションがマッハなソース

[scrollman]

今セキュリティの知識を入れようとしたらパンクしちゃいますし、セキュリティはとりあえず全部を組み終わってからじっくり見直しかなーと…。

Answer 1

クエリが間違っているからですね。

$stmt = $pdo->query("DELETE FROM consumercourse WHERE planid='test'");

---

$pdo = new PDO("mysql:dbname=$db_datebase_6;host=$db_address_3;charset=utf8",$db_user,$db_password, [PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION]);

↑ 第4引数を設定しましょう。

---

サンプル

すぐに理解は難しいかもしれませんが、ざっくりと動きがわかればOKかと。

<?php

/**
 * common.php
 *
 * @author Kosuke Shibuya <[e-mail]>
 * @since 2018/09/04
 */
function h($string)
{
	return htmlspecialchars($string, ENT_QUOTES, 'utf-8');
}

function get_pdo($host, $dbname)
{
	$dsn = sprintf('mysql:host=%s;dbname=%s;charset=utf8mb4'
		, $host
		, $dbname
	);
	$user = 'root';
	$password = 'password';
	$options = [
		PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION
	];
	return new PDO($dsn, $user, $password, $options);
}

function select($host, $dbname, $sql, $params = [])
{
	$pdo = get_pdo($host, $dbname);
	$stmt = $pdo->prepare($sql);
	$stmt->execute($params);
	return $stmt->fetchAll();
}

function delete($host, $dbname, $sql, $params = [])
{
	$pdo = get_pdo($host, $dbname);
	$stmt = $pdo->prepare($sql);
	return $stmt->execute($params);
}

function get_hosts()
{
	return [
		'hogehoge.phy.lolipop.lan'
		, 'hogehoge.phy.lolipop.lan'
		, 'hogehoge.phy.lolipop.lan'
	];
}

function get_database()
{
	return [
		'LAA0547874-hogehogehoge'
		, 'LAA0547874-hogehogehoge'
		, 'LAA0547874-hogehogehoge'
		, 'LAA0547874-hogehogehoge'
		, 'LAA0547874-hogehogehoge'
	];
}

function get_courses()
{
	$host = filter_input(INPUT_GET, 'host');
	$dbname = filter_input(INPUT_GET, 'dbname');

	if ($host == '' || $dbname == '') {
		return;
	}

	$sql = 'SELECT * FROM `consumercourse`';
	return select($host, $dbname, $sql);
}

function delete_course()
{
	$host = filter_input(INPUT_GET, 'host');
	$dbname = filter_input(INPUT_GET, 'dbname');
	$planid = filter_input(INPUT_GET, 'planid');

	if ($host == '' || $dbname == '' || $planid == '') {
		throw new Exception('パラメーターが不正です。');
	}

	$sql = 'DELETE FROM consumercourse WHERE planid = :planid';
	$params = [];
	$params[':planid'] = $planid;
	return delete($host, $dbname, $sql, $params);
}

<?php
/**
 * index.php
 */
// 開発時にエラーを表示する
ini_set('display_errors', true);
error_reporting(E_ALL);

// 共通関数読み込み
require_once 'common.php';

$hosts = get_hosts();
$databases = get_database();
$courses = get_courses();
?>
<!DOCTYPE HTML>
<html lang="ja">
	<head>
		<meta charset="UTF-8">
		<title></title>
	</head>
	<body>
		<div>
			<form action="">
				<p>
					<label for="host">ホスト</label>
					<select name="host" id="host">
						<?php foreach ($hosts as $host) : ?>
							<option value="<?php echo h($host); ?>"><?php echo h($host); ?></option>
						<?php endforeach; ?>
					</select>
				</p>
				<p>
					<label for="dbname">データベース</label>
					<select name="dbname" id="dbname">
						<?php foreach ($databases as $db) : ?>
							<option value="<?php echo h($db); ?>"><?php echo h($db); ?></option>
						<?php endforeach; ?>
					</select>
				</p>
			</form>
		</div>
		<div>
			<p>コース一覧</p>
			<?php if (!is_null($courses)) : ?>
				<table>
					<thead>
						<tr>
							<th>planid</th>
							<th>planname</th>
							<th>plandescription</th>
							<th>initialfee</th>
							<th>monthlycost</th>
							<th>video</th>
							<th>consultation</th>
							<th></th>
							<th></th>
						</tr>
					</thead>
					<tbody>
						<?php foreach ($courses as $course): ?>
							<tr>
								<td><?php echo h($course['planid']); ?></td>
								<td><?php echo h($course['planname']); ?></td>
								<td><?php echo h($course['plandescription']); ?></td>
								<td><?php echo h($course['initialfee']); ?></td>
								<td><?php echo h($course['monthlycost']); ?></td>
								<td><?php echo h($course['video']); ?></td>
								<td><?php echo h($course['consultation']); ?></td>
								<td>
									<a href="delete.php?host=<?php echo filter_input(INPUT_GET, 'host'); ?>&dbname=<?php echo filter_input(INPUT_GET, 'dbname'); ?>&planid=<?php echo h($course['planid']); ?>">削除する</a>
								</td>
							</tr>
						<?php endforeach; ?>
					</tbody>
				</table>
			<?php else: ?>
				<p>ホスト、データベースを選択してください。</p>
			<?php endif; ?>
		</div>
	</body>
</html>

<?php

/**
 * delete.php
 */
// 開発時にエラーを表示する
ini_set('display_errors', true);
error_reporting(E_ALL);

// 共通関数読み込み
require_once 'common.php';

delete_course();

Comments

[scrollman]

お早い回答ありがとうございます。
お陰様で動きました。
引数のほうは了解です。
ちなみに、SQL文の変数代入はどのようにすればよろしいのでしょうか？
$stmt = $pdo->query("DELETE FROM consumercourse WHERE planid='' . $planid . ''");
このようにしてみたのですが、動かなくて…

[退会済みユーザー]

「変数代入」とはなんのことを言っているんですか？

[scrollman]

差し支えなければ、
$stmt = $pdo->query("DELETE FROM consumercourse WHERE planid='' . $planid . ''");
planのほうに変数を代入する方法を教えていただきたいです。

[退会済みユーザー]

質問するのはいいんだけど、ちゃんと説明すべきことを説明してくれないかな？

$planid ってだいたいどこに由来するもの？ユーザーが任意で番号を指定する？フォームからくる？
その辺の説明なしに何をしてくれと言うんだい？

だいたいのコード、今突然出てきているんだが。質問文にそのコード書かれてないよ。

[scrollman]

申し訳ございません。

元々このPHPファイルはレコード消去用のものでして、
URLパラメーターから
planidを取得し、
それをSQL文に代入して処理をする、ようにするのが最終到達時点だったのです。

取得するところまでは出来ているので、後はそれをSQL文に当てはめる方法を教えていただければ助かります。

新しい質問のほうで質問したほうがよかったでしょうか…？

[退会済みユーザー]

質問文に追記してください。HTMLからパラメータを渡すところから。

[scrollman]

了解いたしました。

[scrollman]

これで質問できますでしょうか？

[退会済みユーザー]

function とか、require はまだ使ったことない感じですか？
使ったことなくてもいいけど、理解できる範囲ですかね？

[scrollman]

function
⇨関数作れたりして他でいろいろ使えるんだなー
require
⇨別のPHPファイル読み込めるんだなー

という認識です…。

[退会済みユーザー]

PHP以外に理解できる言語もない感じですか？

[scrollman]

そうですね、
昔ちょっとだけVBSやったなー
ぐらいなものです。

[退会済みユーザー]

直すべきところが多すぎるので、ほぼ全面書き直しになるけど構わないですかね？

[scrollman]

少しでも学べればと思います。

差し支えなければお願いいたします。

[退会済みユーザー]

$_GET['courseselect'];の由来が不明です

[scrollman]

上位のファイル内容を追記いたしました。

[退会済みユーザー]

DBやホストを外部から与えられると言う仕様は危険なので、バリデーションを加える必要があります。なのでリストでもって、チェック可能な拡張ができるようにしています。get_pdo() の中でチェックすればOKでしょう。

[scrollman]

夜遅くに（もう夜明けか）こんなに長いコードを書いてくれてありがとうございました。
すぐに応用！とかは難しいですが、じっくり読んでいつかはものにできればと思います。

[退会済みユーザー]

コピペして動いた！ラッキーで終わらせないでくださいね。
データベースまでは作って試してはいないので、多少ミスはあるだろうけど。