phpコード内でSQLクエリを実行したい

Question

前提・実現したいこと

現在とあるphpコード内でSQLクエリを実行して定期的にそのSQLクエリが実行される
ようにしたいのですが、うまく行きません。

発生している問題・エラーメッセージ

ブラウザ上では特にエラーなどは起きていないように思います。エラーログを
確認したいのですが、その方法が分かりません。
サーバーはロリポップを使用しており、php.iniのdisplay_errorsをOnにしたのですが
エラーが表示されない状況です。

該当のソースコード

public function updateMemberRelationship()
{
    $conn = "host=mysql105.XXX.XXXX.lan dbname=XXXX user=XXXX password=XXXX";
    $link = pg_connect($conn);
	if (!$link) {
	    die('接続失敗です。'.pg_last_error());
	}

	print('接続に成功しました。<br>');

	$query = "INSERT INTO member_relationship(member_id_to, member_id_from, is_friend, created_at, updated_at);";
	$query .= "SELECT i.id,you.id,1,NOW(),NOW();";
	$query .= "FROM member i;";
	$query .= "JOIN member you;";
	$query .= "ON i.id <> you.id;";
	$query .= "LEFT OUTER JOIN member_relationship relation;";
	$query .= "ON relation.member_id_to = i.id AND relation.member_id_from = you.id;";
	$query .= "WHERE relation.id IS NULL;";
	
	$result = pg_query($conn, $query);

	if (!$result) {
	    die('クエリーが失敗しました。'.pg_last_error());
	}

	$close_flag = pg_close($link);

	if ($close_flag){
	    print('切断に成功しました。<br>');
	}
  }

public function executeRegisterInput(opWebRequest $request)
{
    $this->forward404Unless(opToolkit::isEnabledRegistration((sfConfig::get('app_is_mobile') ? 'mobile' : 'pc')));

    $this->token = $request['token'];
    $member = $this->getUser()->setRegisterToken($this->token);

    $this->forward404Unless($member && $this->getUser()->isRegisterBegin());
    opActivateBehavior::disable();
    $this->form = $this->getUser()->getAuthAdapter()->getAuthRegisterForm();
    opActivateBehavior::enable();

    if ($request->isMethod('post'))
    {
      $this->form->bindAll($request);

      if ($this->form->isValidAll())
      {
        $result = $this->getUser()->register($this->form);
        $this->redirectIf($result, $this->getUser()->getRegisterEndAction($this->token));
      }
    }
    updateMemberRelationship();
    return sfView::SUCCESS;
}

試したこと

こちらの情報の「会員を全員友達にする」に記載されているQueryをロリポップのphpMyAdminにて手動実行することで
目的の動作は実現できているのですが、こちらのQueryをphpコード内で実行できれば
自動化できるのではないかということで、こちらの質問に至りました。

補足情報（FW/ツールのバージョンなど）

OpenPNE3.8.28　こちらからダウンロードできます
phpバージョン5.6(ロリポップコンパネから設定)
ロリポップサーバースペック
スタンダードプランを使用

以上、よろしくお願いいたします。

Comments

[yambejp]

postgreSQLですよね？phpMyAdminカテゴリは関係ないのではずして postgreにつけかえてください

[JunTokita]

失礼しました。タグをMySQLに付け替えました。

[yambejp]

あ、読み違えました。mysqlなのですね？であればpg_系の関数を利用している部分がおかしいです。できればpdoで処理されると良いと思います

[退会済みユーザー]

コード内のサーバー名やユーザー名はfakeですよね？ ロリポに迷惑かからなければいいですが。

[JunTokita]

実コードを上げてしまったので、コードを伏せました。失礼しました。

[m.ts10806]

編集履歴から確認できるので削除依頼だしたほうがいいです。回答がついてしまっているので直接運営に問い合わせしてください。

Answer 1

データベースサーバーはmysqlなので、
mysqli_*系関数もしくはPDO接続でないとつながらないですよね。
pg_*系はあくまでPostgreSQL専用ですので。

mysqlデータベースに接続する方法の解説記事：
PHPでデータベースに接続するときのまとめ - Qiita
内容が濃厚ですので一度で理解できないかもしれませんが、
とても重要なことが散りばめられているので
きちんと理解できるよう頑張ってください。

SQL文それぞれ、
後ろに「;」あるのはジョークですか？
SQL文で「;」は文の終わりを意味しているので、
まともに動かないんじゃないかなと。

<?php

    $query = "INSERT INTO member_relationship(member_id_to, member_id_from, is_friend, created_at, updated_at);";
    $query .= "SELECT i.id,you.id,1,NOW(),NOW();";
    $query .= "FROM member i;";
    $query .= "JOIN member you;";
    $query .= "ON i.id <> you.id;";
    $query .= "LEFT OUTER JOIN member_relationship relation;";
    $query .= "ON relation.member_id_to = i.id AND relation.member_id_from = you.id;";
    $query .= "WHERE relation.id IS NULL;";
    
    var_dump($query);

string(318) "INSERT INTO member_relationship(member_id_to, member_id_from, is_friend, created_at, updated_at);SELECT i.id,you.id,1,NOW(),NOW();FROM member i;JOIN member you;ON i.id <> you.id;LEFT OUTER JOIN member_relationship relation;ON relation.member_id_to = i.id AND relation.member_id_from = you.id;WHERE relation.id IS NULL;"

こんなSQL文になってますよ。

<?php

    $query = <<<EOT
INSERT INTO member_relationship(member_id_to, member_id_from, is_friend, created_at, updated_at) 
SELECT i.id,you.id,1,NOW(),NOW() 
FROM member i 
JOIN member you 
ON i.id <> you.id 
LEFT OUTER JOIN member_relationship relation 
ON relation.member_id_to = i.id AND relation.member_id_from = you.id 
WHERE relation.id IS NULL;
EOT;
    
    var_dump($query);

string(325) "INSERT INTO member_relationship(member_id_to, member_id_from, is_friend, created_at, updated_at) SELECT i.id,you.id,1,NOW(),NOW() FROM member i JOIN member you ON i.id <> you.id LEFT OUTER JOIN member_relationship relation ON relation.member_id_to = i.id AND relation.member_id_from = you.id WHERE relation.id IS NULL;"

ならとりあえず動きそうなSQL文になる気がします。

Answer 2

mysqlで接続しているのに、pg_connectは使えないですよ。pg_connectはあくまでpostgreSQL接続用の、拡張関数です。mysqli_connectを使うか、PDOで接続しなおしましょう。

※mysql_connectで説明しているページも多いので、データベース初心者なら、それでまずは接続してみるという手もありです。ただ、PHP5.5以降は非推奨、PHP7以降は削除なので、あとでmysqli_connectに書き換えるといいです。

Comments

[退会済みユーザー]

今どきmysql_*系を回答するとは。mysqli_*系に訂正したほうがいいんじゃないでしょうか。

[FKM]

現場でPDOしか使っていないので、mysqli系をあまり意識してませんでした…修正しておきました。