<?php

//elasticSearch地址
$elasticSearchUrl = 'http://127.0.0.1:9200/_bulk';
echo 'elasticSearch地址';
echo "<br/>";
echo $elasticSearchUrl;

$servername = "127.0.0.1";
$username = "username";
$password = "password";
$dbname = 'dbname';

// 创建连接
$conn = new mysqli($servername, $username, $password, $dbname);
echo "<br/>";
// 检测连接
if ($conn->connect_error) {
    die("连接失败: " . $conn->connect_error);
}else{
    echo "连接成功";
}

echo "<br/>";
echo date('Y-m-d:h:i:sa',time());
$sql = "SELECT id, sender_id, sender_phone,receiver,receiver_id,receiver_phone FROM delivery_sheets limit 100000 offset 300000";
$result = $conn->query($sql);
$multData = '';

if ($result->num_rows > 0) {
    // 输出数据
    while($row = $result->fetch_assoc()) {

        $multData .= '{ "create": { "_index": "library", "_type": "books", "_id": '.$row["id"].'}}'."\r\n";
        $multData .= '{"doc":'.json_encode($row).'}'."\r\n";

    }

    $res = curl($elasticSearchUrl,'POST',$multData,'');

    echo "<br/>";
    echo date('Y-m-d:h:i:sa',time());
    echo "<br/>";
    echo 'success';
}

//----------

function curl($url,$method,$params,$auth=''){
    //初始化CURL句柄
    $curl = curl_init();

    curl_setopt($curl, CURLOPT_URL, $url);//设置请求的URL
    #curl_setopt($curl, CURLOPT_HEADER, false);// 不要http header 加快效率
    curl_setopt($curl, CURLOPT_RETURNTRANSFER,1); //设为TRUE把curl_exec()结果转化为字串，而不是直接输出

    //SSL验证
    curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE);    // https请求时要设置为false 不验证证书和hosts  FALSE 禁止 cURL 验证对等证书（peer's certificate）, 自cURL 7.10开始默认为 TRUE。从 cURL 7.10开始默认绑定安装。
    curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE);//检查服务器SSL证书中是否存在一个公用名(common name)。

    $header[] = "Content-Type:application/json;charset=utf-8";
    if(!empty($header)){
        curl_setopt ( $curl, CURLOPT_HTTPHEADER, $header );//设置 HTTP 头字段的数组。格式： array('Content-type: text/plain', 'Content-length: 100')
    }

    //请求时间
    $timeout = 30;
    curl_setopt ($curl, CURLOPT_CONNECTTIMEOUT, $timeout);//设置连接等待时间

    //不同请求方法的数据提交
    switch ($method){
        case "GET" :
            curl_setopt($curl, CURLOPT_HTTPGET, true);//TRUE 时会设置 HTTP 的 method 为 GET，由于默认是 GET，所以只有 method 被修改时才需要这个选项。
            break;
        case "POST":
//            if(is_array($params)){
//                $params = json_encode($params,320);
//            }
            #curl_setopt($curl, CURLOPT_POST,true);//TRUE 时会发送 POST 请求，类型为：application/x-www-form-urlencoded，是 HTML 表单提交时最常见的一种。
            #curl_setopt($curl, CURLOPT_NOBODY, true);//TRUE 时将不输出 BODY 部分。同时 Mehtod 变成了 HEAD。修改为 FALSE 时不会变成 GET。
            curl_setopt($curl, CURLOPT_CUSTOMREQUEST, "POST");//HTTP 请求时，使用自定义的 Method 来代替"GET"或"HEAD"。对 "DELETE" 或者其他更隐蔽的 HTTP 请求有用。 有效值如 "GET"，"POST"，"CONNECT"等等；
            //设置提交的信息
            curl_setopt($curl, CURLOPT_POSTFIELDS,$params);//全部数据使用HTTP协议中的 "POST" 操作来发送。
            break;
        case "PUT" :
            curl_setopt($curl, CURLOPT_CUSTOMREQUEST, "PUT");
            curl_setopt($curl, CURLOPT_POSTFIELDS,json_encode($params,320));
            break;
        case "DELETE":
            curl_setopt($curl, CURLOPT_CUSTOMREQUEST, "DELETE");
            curl_setopt($curl, CURLOPT_POSTFIELDS,$params);
            break;
    }

    //传递一个连接中需要的用户名和密码，格式为："[username]:[password]"。
    if (!empty($auth) && isset($auth['username']) && isset($auth['password'])) {
        curl_setopt($curl, CURLOPT_USERPWD, "{$auth['username']}:{$auth['password']}");
    }

    $data = curl_exec($curl);//执行预定义的CURL
    $status = curl_getinfo($curl, CURLINFO_HTTP_CODE);//获取http返回值,最后一个收到的HTTP代码
    curl_close($curl);//关闭cURL会话
    $res = json_decode($data,true);

    return $res;
}