2017-08-14 51 views
0

我有一个运行在powershell中的php文件/脚本,它意味着连接到一个数据库服务器,选择信息,连接到另一个数据库/服务器并插入该信息。未定义的索引错误,文件中的多个数据库连接

我有连接问题,但现在我有它的工作,除非我在PowerShell中运行此脚本我得到了一个错误,5是确切的(它与数据库中的记录匹配当前)关于undefined指数。

这会影响第51行到第55行,它们恰好是我的代码的末尾,VALUES部分,从ON DUPLICATE KEY行开始。我在mysql工作台中的表具有完全相同的列名,索引值等,我的测试表具有执行此脚本以在工作台中进行测试的位置。我是否在我的插入语句中错误地调用了这些值?

<?php 

    $servername = "//"; 
    $username = "//"; 
    $password = "//"; 

    $servername2 = "//"; 
    $username2 = "//"; 
    $password2 = "//"; 

    // Create connection 
    $conn = new mysqli($servername, $username, $password); 
    $conn2 = new mysqli($servername2, $username2, $password2); 

    // Check connection 
    if ($conn->connect_error) { 
     die("Connection failed: " . $conn->connect_error); 
    } 
    echo "Connected successfully"; 

    // Check connection2 
    if ($conn2->connect_error) { 
     die("Connection failed: " . $conn2->connect_error); 
    } 
    echo "Connected successfully"; 

    $data = mysqli_query($conn, " SELECT c.extension 
          ,RESPONSIBLEUSEREXTENSIONID 
          , sum(Duration) AS Total_Talk_Time_seconds 
          , round(sum(Duration)/60,2) AS Total_Talk_Time_minutes 
          , sum(if(LEGTYPE1 = 1,1,0)) AS Total_Outbound 
          , sum(if(LEGTYPE1 = 2,1,0)) AS Total_Inbound 
          , sum(if(Answered = 1,0,1)) AS Total_Missed 
          , count(DISTINCT b.NOTABLECALLID) AS Total_Calls 
          , NOW() AS time 
          , curdate() AS date 
         FROM cdrdb.session a 
         LEFT JOIN cdrdb.callsummary b 
          ON a.NOTABLECALLID = b.NOTABLECALLID 
         LEFT join cdrdb.mxuser c 
          ON a.RESPONSIBLEUSEREXTENSIONID = c.EXTENSIONID 
         WHERE b.ts >= curdate() 
         AND c.extension IN (7295,7306,7218,7247,7330,7000,7358) 
         group by c.extension"); 


      foreach ($data as $d) { 

        $stmt = mysqli_prepare($conn2, "Insert into jfi.ambitionphone(Extension, ExtID, Total_Talk_Time_seconds, 
          Total_Talk_Time_minutes,Total_Outbound, Total_Inbound, 
          Missed_Calls, Total_Calls, Time_of_report,Date_of_report ) 
          VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?) 
          ON duplicate key update 
          Total_Talk_Time_seconds = values(Total_Talk_Time_seconds), 
          Total_Talk_Time_minutes = values(Total_Talk_Time_minutes), 
          Total_Outbound = values(Total_Outbound), 
          Total_Inbound = values(Total_Inbound), 
          Missed_calls = values(Missed_Calls), 
          Total_Calls = values(Total_Calls), 
          Time_of_report = values(Time_of_report), 
          Date_of_report = values(Date_of_report)"); 
          mysqli_stmt_bind_param($stmt, "ssiiiiiiss", $d['extension'], $d['RESPONSIBLEUSEREXTENSIONID'], 
          $d['Total_Talk_Time_seconds'], $d['Total_Talk_Time_minutes'], 
          $d['Total_Outbound'], $d['Total_Inbound'], $d['Total_Missed'], $d['Total_Calls'], 
          $d['time'], $d['date']); 

      mysqli_stmt_execute($stmt); 

      } 

    ?> 

UPDATE:

这是MySQL查询,我将这个PHP脚本,用于上下文:

Insert into test.ambition_test(Extension, ExtID, Total_Talk_Time_seconds, 
Total_Talk_Time_minutes,Total_Outbound, Total_Inbound, 
Missed_Calls, Total_Calls, Time_of_report,Date_of_report ) 
SELECT 
c.extension 
,RESPONSIBLEUSEREXTENSIONID 
, sum(Duration) 
, round(sum(Duration)/60,2) 
, sum(if(LEGTYPE1 = 1,1,0)) 
, sum(if(LEGTYPE1 = 2,1,0)) 
, sum(if(Answered = 1,0,1)) 
-- , count(DISTINCT b.NOTABLECALLID) as Total_Calls 
, sum(if(LEGTYPE1 = 1,1,0)) + sum(if(LEGTYPE1 = 2,1,0)) as total_calls 
, NOW() 
, curdate() 
FROM cdrdb.session a 
LEFT JOIN cdrdb.callsummary b 
ON a.NOTABLECALLID = b.NOTABLECALLID 
LEFT join cdrdb.mxuser c 
ON a.RESPONSIBLEUSEREXTENSIONID = c.EXTENSIONID 
WHERE b.ts >= curdate() 
AND c.extension IN (7295,7306,7218,7247,7330,7000,7358) 
group by c.extension 
ON duplicate key update Total_Talk_Time_seconds 
=values(Total_Talk_Time_seconds), 
Total_Talk_Time_minutes =values(Total_Talk_Time_minutes), 
Total_Outbound = values(Total_Outbound), 
Total_Inbound = values(Total_Inbound), 
Missed_calls = values(Missed_calls), 
Total_Calls = values(Total_Calls), 
Time_of_report = NOW(); 
+3

你不必在查询中用'while()'而不是'foreach()'获取结果吗? – Rasclatt

+1

很确定你是对的@Rasclatt,因为它不是PDO – GrumpyCrouton

+0

,所以我会沿着'''的方向做一些事情,而($ row = mysql_fetch_array)'''?对不起,我不知道我将使用的确切语法 –

回答

1

的问题是,你没有指定别名功能在第一个查询中调用。所以没有列命名为Total_OutboundTotal_Inbound,等它应该是:

$data = mysqli_query($conn, " SELECT c.extension 
           ,RESPONSIBLEUSEREXTENSIONID 
           , sum(Duration) AS Total_Talk_Time_seconds 
           , round(sum(Duration)/60,2) AS Total_Talk_Time_minutes 
           , sum(if(LEGTYPE1 = 1,1,0)) AS Total_Outbound 
           , sum(if(LEGTYPE1 = 2,1,0)) AS Total_Inbound 
           , sum(if(Answered = 1,0,1)) AS Total_Missed 
           , count(DISTINCT b.NOTABLECALLID) AS Total_Calls 
           , NOW() AS time 
           , curdate() AS date 
          FROM cdrdb.session a 
          LEFT JOIN cdrdb.callsummary b 
           ON a.NOTABLECALLID = b.NOTABLECALLID 
          LEFT join cdrdb.mxuser c 
           ON a.RESPONSIBLEUSEREXTENSIONID = c.EXTENSIONID 
          WHERE b.ts >= curdate() 
          AND c.extension IN (7295,7306,7218,7247,7330,7000,7358) 
          group by c.extension"); 

那么你还需要修复您INSERT查询的语法。它没有指定要插入的值,那么它应该如何判断您是否创建了重复密钥?而且您应该使用准备好的声明来避免引用问题。

$stmt = mysqli_prepare($conn2, "Insert into jfi.ambitionphone(Extension, ExtID, Total_Talk_Time_seconds, 
         Total_Talk_Time_minutes,Total_Outbound, Total_Inbound, 
         Missed_Calls, Total_Calls, Time_of_report,Date_of_report ) 
         VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?) 
         ON duplicate key update 
         Total_Talk_Time_seconds = values(Total_Talk_Time_seconds), 
         Total_Talk_Time_minutes = values(Total_Talk_Time_minutes), 
         Total_Outbound = values(Total_Outbound), 
         Total_Inbound = values(Total_Inbound), 
         Missed_calls = values(Missed_Calls), 
         Total_Calls = values(Total_Calls), 
         Time_of_report = values(Time_of_report), 
         Date_of_report = values(Date_of_report)"); 

foreach ($data as $d) { 
    mysqli_stmt_bind_param($stmt, "ssiiiiiiss", $d['extension'], $d['RESPONSIBLEUSEREXTENSIONID'], 
     $d['Total_Talk_Time_seconds'], $d['Total_Talk_Time_minutes'], 
     $d['Total_Outbound'], $d['Total_Inbound'], $d['Total_Missed'], $d['Total_Calls'], 
     $d['time'], $d['date']); 
    mysqli_stmt_execute($stmt); 
} 
+0

谢谢,$ stmt块,所有这些都在我的foreach循环中,是否正确? –

+0

实际上,你只需要在循环之外调用'prepare'和'bind_param'一次。 – Barmar

+0

对不起,我只是有点困惑,我认为选择查询必须在循环之外完成以创建$ data变量。我更新了上面的代码,但我不确定要从foreach循环中删除什么 –