10

私はこれまでmysqli_multi_queryを使用したことがなく、頭がおかしくなりました。ネット上で見つけた例は、私が何をしたいのかを正確に理解するのに役立ちません。

これが私のコードです：

<?php

    $link = mysqli_connect("server", "user", "pass", "db");

    if (mysqli_connect_errno()) {
        printf("Connect failed: %s\n", mysqli_connect_error());
        exit();
    }

    $agentsquery = "CREATE TEMPORARY TABLE LeaderBoard (
        `agent_name` varchar(20) NOT NULL,
        `job_number` int(5) NOT NULL,
        `job_value` decimal(3,1) NOT NULL,
        `points_value` decimal(8,2) NOT NULL
    );";
    $agentsquery .= "INSERT INTO LeaderBoard (`agent_name`, `job_number`, `job_value`, `points_value`) SELECT agent_name, job_number, job_value, points_value FROM jobs WHERE YEAR(booked_date) = $current_year && WEEKOFYEAR(booked_date) = $weeknum;";
    $agentsquery .= "INSERT INTO LeaderBoard (`agent_name`) SELECT DISTINCT agent_name FROM apps WHERE YEAR(booked_date) = $current_year && WEEKOFYEAR(booked_date) = $weeknum;";
    $agentsquery .= "SELECT agent_name, SUM(job_value), SUM(points_value) FROM leaderboard GROUP BY agent_name ORDER BY SUM(points_value) DESC";

    $i = 0;
    $agentsresult = mysqli_multi_query($link, $agentsquery);

    while ($row = mysqli_fetch_array($agentsresult)){
        $number_of_apps = getAgentAppsWeek($row['agent_name'],$weeknum,$current_year);
        $i++;
?>

            <tr class="tr<?php echo ($i & 1) ?>">
                <td style="font-weight: bold;"><?php echo $row['agent_name'] ?></td>
                <td><?php echo $row['SUM(job_value)'] ?></td>
                <td><?php echo $row['SUM(points_value)'] ?></td>
                <td><?php echo $number_of_apps; ?></td>
            </tr>

<?php

    }
?>

私がやろうとしているのは、複数のクエリを実行し、それらの4つのクエリの最終結果を使用して、それらをテーブルに配置することだけです。

上記のコードは実際にはまったく機能しません。次のエラーが発生します。

警告：mysqli_fetch_array（）は、パラメーター1がmysqli_resultであると想定しています。ブール値は、391行目のC：\ xampp \ htdocs \ Hydroboard\hydro_reporting_2010.phpで指定されています。

何か助けはありますか？

4

6 に答える 6

8

マニュアルから：成功を示すものを mysqli_multi_query()返します。bool

最初のクエリから結果セットを取得するには、mysqli_use_result（）またはmysqli_store_result（）を使用できます。以降のすべてのクエリ結果は、mysqli_more_results（）およびmysqli_next_result（）を使用して処理できます。

マルチクエリの最後の結果を返す関数は次のとおりです。

function mysqli_last_result($link) {
    while (mysqli_more_results($link)) {
        mysqli_use_result($link); 
        mysqli_next_result($link);
    }
    return mysqli_store_result($link);
}

使用法：

$link = mysqli_connect();

$query  = "SELECT 1;";
$query .= "SELECT 2;";
$query .= "SELECT 3";

mysqli_multi_query($link, $query);
$result = mysqli_last_result($link);
$row = $result->fetch_row();
echo $row[0];  // prints "3"

$result->free();
mysqli_close($link);
于 2011-01-12T10:22:45.177 に答える
4

試行錯誤を繰り返し、Google検索で見つけた別の投稿を参照した後、問題を解決することができました。

新しいコードは次のとおりです。

<?php

    $link = mysqli_connect("server", "user", "pass", "db");

    if (mysqli_connect_errno()) {
        printf("Connect failed: %s\n", mysqli_connect_error());
        exit();
    }

    $agentsquery = "CREATE TEMPORARY TABLE LeaderBoard (
        `agent_name` varchar(20) NOT NULL,
        `job_number` int(5) NOT NULL,
        `job_value` decimal(3,1) NOT NULL,
        `points_value` decimal(8,2) NOT NULL
    );";
    $agentsquery .= "INSERT INTO LeaderBoard (`agent_name`, `job_number`, `job_value`, `points_value`) SELECT agent_name, job_number, job_value, points_value FROM jobs WHERE YEAR(booked_date) = $current_year && WEEKOFYEAR(booked_date) = $weeknum;";
    $agentsquery .= "INSERT INTO LeaderBoard (`agent_name`) SELECT DISTINCT agent_name FROM apps WHERE YEAR(booked_date) = $current_year && WEEKOFYEAR(booked_date) = $weeknum;";
    $agentsquery .= "SELECT agent_name, SUM(job_value), SUM(points_value) FROM leaderboard GROUP BY agent_name ORDER BY SUM(points_value) DESC";

    mysqli_multi_query($link, $agentsquery) or die("MySQL Error: " . mysqli_error($link) . "<hr>\nQuery: $agentsquery");
    mysqli_next_result($link);
    mysqli_next_result($link);
    mysqli_next_result($link);

    if ($result = mysqli_store_result($link)) {
        $i = 0;
        while ($row = mysqli_fetch_array($result)){
            $number_of_apps = getAgentAppsWeek($row['agent_name'],$weeknum,$current_year);
            $i++;
?>

            <tr class="tr<?php echo ($i & 1) ?>">
                <td style="font-weight: bold;"><?php echo $row['agent_name'] ?></td>
                <td><?php echo $row['SUM(job_value)'] ?></td>
                <td><?php echo $row['SUM(points_value)'] ?></td>
                <td><?php echo $number_of_apps; ?></td>
            </tr>

<?php

        }
    }
?>

mysqli_next_resultをクエリごとに複数回貼り付けた後、魔法のように機能しました。わーい！次の結果に3回スキップするように指示しているので、なぜ機能するのか理解しています。したがって、使用したいクエリ＃4の結果にスキップします。

私には少し不格好なようですが、mysqli_last_result（$ link）などのコマンドが必要です...

ヘルプリックとf00をありがとう、私は最終的にそこに着きました:)

于 2011-01-12T11:03:24.253 に答える
1

リーダー/エージェントの統計を生成するストアドプロシージャを作成し、次のようにphpから呼び出す（1回の呼び出し）ことで、実行しようとしていることを単純化します。

ここに完全なスクリプト：http：//pastie.org/1451802

または、個々のクエリを1つのselect /groupbyステートメントに結合することもできます。

ここを参照してください：http：//pastie.org/1451842

select
 leaders.agent_name, 
 sum(leaders.job_value) as sum_job_value, 
 sum(leaders.points_value) as sum_points_value 
from
(
select 
 agent_name, 
 job_number, 
 job_value, 
 points_value 
from 
 jobs 
where 
 year(booked_date) = 2011 and weekofyear(booked_date) = 2
union all
select distinct
 agent_name,
 0,0,0
from
 apps
where 
 year(booked_date) = 2011 and weekofyear(booked_date) = 2
) leaders
group by
 agent_name 
order by sum_points_value desc;

ストアドプロシージャ

drop procedure if exists list_leaders;

delimiter #
create procedure list_leaders
(
in p_year smallint unsigned,
in p_week tinyint unsigned
)
begin

  create temporary table tmp_leaders(
    agent_name varchar(20) not null,
    job_number int unsigned not null default 0, -- note the default values
    job_value decimal(3,1) not null default 0,
    points_value decimal(8,2) not null default 0
  )engine=memory;

  insert into tmp_leaders (agent_name, job_number, job_value, points_value) 
    select agent_name, job_number, job_value, points_value from jobs 
    where year(booked_date) = p_year and weekofyear(booked_date) = p_week;

  insert into tmp_leaders (agent_name) -- requires default values otherwise you will get nulls
    select distinct agent_name from apps
    where year(booked_date) = p_year and weekofyear(booked_date) = p_week;

  select 
    agent_name, 
    sum(job_value) as sum_job_value, 
    sum(points_value) as sum_points_value 
   from
    tmp_leaders
   group by
    agent_name order by sum_points_value desc;

  drop temporary table if exists tmp_leaders;

end#

delimiter ;

call list_leaders(year(curdate()), weekofyear(curdate()));

PHPスクリプト

<?php

ob_start(); 

try
{
    $db = new mysqli("localhost", "foo_dbo", "pass", "foo_db", 3306);

    if ($db->connect_errno) 
        throw new exception(sprintf("Could not connect: %s", $db->connect_error));

    $sqlCmd = "call list_leaders(2011, 2)";
    $result = $db->query($sqlCmd);

    if(!$result) throw new exception(sprintf("Invalid query : %s", $sqlCmd));

    if($db->affected_rows <= 0){
        echo "no leaders found !";
    }
    else{
        $leaders = $result->fetch_all(MYSQLI_ASSOC);
        foreach($leaders as $ldr){
            // do stuff
            echo $ldr["agent_name"], "<br/>";
        }
    }
}
catch(exception $ex)
{
    ob_clean(); 
    echo sprintf("zomg borked - %s", $ex->getMessage());
}

if(!$db->connect_errno) $db->close();
ob_end_flush();
?>

ちょっと簡単になりました-お役に立てば幸いです:)

于 2011-01-12T10:52:46.553 に答える
1

結果を変数に格納し、最終的にその変数を使用します。

    do{
        if($result = $con->store_result()){
            $data=$result->fetch_all();
            $result->free();
        }
    } while($con->more_results()&&$con->next_result());
    echo(json_encode($data));
于 2017-07-28T13:32:42.310 に答える
0

ポスターの現在受け入れられている解決策を整理して、ベストプラクティスと考えているものにさらに合わせるようにしたいと思います。

  • mysqli_next_result（$ link）の複数の行は意図した結果を提供しますが、少しハックに見えます。そこで、代わりにDO-WHILEを作成します。
  • 関数mysqli_last_result（$ link）の作成を含むrikのソリューションは不要です。私のWHILE条件は、同じ効果を達成します。さらに、rikのコードは手続き型とオブジェクト指向のスタイルを組み合わせていますが、これは避ける必要があります。
  • phpとhtmlの間を行き来することはありません。
  • クラスの切り替えを少し調整します。
  • 一度だけ言及される変数を作成したくないので、getAgentAppsWeek（）を直接インラインに配置します。そして、HarryWeinertが関数に名前を付けるのに良い仕事をしたからです。

  • IMOこれは読みやすいです。

    if(mysqli_multi_query($link,$agentsquery)){
    do{
        if($result=mysqli_store_result($link)){ // ignore if no record set
            while($row=mysqli_fetch_array($result)){
                echo "<tr class=\"tr",(++$i & 1),"\">";
                    echo "<td style=\"font-weight:bold;\">",$row['agent_name'],"</td>";
                    echo "<td>",$row['SUM(job_value)'],"</td>";
                    echo "<td>",$row['SUM(points_value)'],"</td>";
                    echo "<td>",getAgentAppsWeek($row['agent_name'],$weeknum,$current_year),"</td>";
                echo "</tr>";
            }
            mysqli_free_result($result);
        }
    } while(mysqli_more_results($link) && mysqli_next_result($link));
}
if($error_mess=mysqli_error($link)){
    echo "<tr class=\"error\"><td colspan=\"4\">Error: $error_mess</td></tr>";
}
//if any query returns false, mysqli_multi_query will stop
// and the individual query error to blame will be provided.
于 2014-03-18T05:50:52.150 に答える
0

この質問についても、私は自分の帽子をリングに投げ込むと思います（そして、それはまだ手続き型であり、すべてのジャズです）。これは絶対確実ではありませんが、私はMySQLiと戦い、multi_queryに関与している陽気な男性のバンドであり、私が望むようにうまく再生したり、必要な柔軟性を持たせたりすることができませんでした。explode(';', $sql_statements)何人かのプログラマーが単に走っていて、それがどれほどひどく間違っているかで私の目を出血させたいくつかの例を見ました。

私の解決策はあなたにはうまくいかないかもしれませんが、これは私にはうまくいきました。（いいえ、それも防弾ではありませんが、私の特定のアプリケーションの仕事をします）。

<?php
    $file = file_get_contents('test_multiple_queries.sql');
    $result = preg_split("/;(?=\s*(create|insert|update|alter|show|explain|truncate|drop|delete|replace|start|lock|commit|rollback|set|begin|declare|rename|load|begin|describe|help))/im", $file);
    $result = array_map('trim', $result);

    foreach($result as $sql_query) {

        // Procedural style
        $my_query = mysqli_query($link, $sql_query);

        // Now you can get errors easily, or affected_rows, or whatever
        //    using much simpler, readable code
        mysqli_error($link);
        mysqli_affected_rows($link);

        // or go crazy with some other stuff
        $words = preg_split("/\s+/", $sql_query);
        switch(strtolower($words[0])) {
            case 'insert':
                // do something nifty like...
                echo 'New ID: '.mysqli_insert_id($link)."\n";
                break;
            case 'drop':
                // obviously run this before the query, simply here for example
                echo 'Hey young (man|lady)! We don\'t drop anything!';
                break;
            case 'select':
                // hooray for selecting stuff
                while($rs = mysqli_fetch_assoc($my_query)) {
                    // have fun with data
                }
                break;
        }
    }
于 2015-10-06T20:46:40.350 に答える