PDO を使用して InfluxDB データベースに接続する方法

$host = "localhost";  // InfluxDB服务器地址
$port = 8086;  // InfluxDB服务器端口
$database = "mydatabase";  // 数据库名称
$dsn = "influxdb:host=$host;port=$port;dbname=$database";
$username = "myusername";  // InfluxDB用户名
$password = "mypassword";  // InfluxDB密码

try {
    $connection = new PDO($dsn, $username, $password);
    $connection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    echo "成功连接到InfluxDB数据库！";
} catch (PDOException $e) {
    echo "连接到InfluxDB数据库失败：" . $e->getMessage();
}

$query = "SELECT * FROM measurement";
try {
    $statement = $connection->query($query);
    $result = $statement->fetchAll(PDO::FETCH_ASSOC);
    foreach ($result as $row) {
        print_r($row);
    }
} catch (PDOException $e) {
    echo "查询失败：" . $e->getMessage();
}

$measurement = "measurement";
$field1 = "field1";
$field2 = "field2";
$value1 = 10;
$value2 = 20;
$timestamp = time() * 1000000000;  // 将当前时间转换为纳秒

$query = "INSERT INTO $measurement ($field1, $field2, time) VALUES (?, ?, ?)";
try {
    $statement = $connection->prepare($query);
    $statement->execute([$value1, $value2, $timestamp]);
    echo "数据插入成功！";
} catch (PDOException $e) {
    echo "数据插入失败：" . $e->getMessage();
}