Я пытаюсь выбрать и UPSERT
значение в Апач феникс от PHP
Классы. я смогу select
с помощью php curl
запросить сервер, который установлен на порт 8765
Вроде у меня есть доля в примере.
Точно так же я пытаюсь вставить данные(UPSERT)
в Фениксе с использованием PHP Curl. Это дает мне ответ, но данные не вставляются.
<?php
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL,"http://localhost:8765/");
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
$headers = array();
// For Select.
//$headers[] = 'request: {"request":"prepareAndExecute","connectionId":"aaaaaaaa-aaaa-aaaa-aaaa-aaaaaaaaaaaa","sql":"select * from BLOG.POST"}';
// For Upsert.
$headers[] = 'request: {"request":"prepareAndExecute","connectionId":"aaaaaaaa-aaaa-aaaa-aaaa-aaaaaaaaaaaa","sql":"UPSERT INTO BLOG.POST (POST_ID,TITLE,CONTENT) values (\'aa11111\',\'Test Title\',\'this is test post content\')"}';
curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
$server_output = curl_exec ($ch);
curl_close ($ch);
{"response":"Service$ExecuteResponse","results":[{"response":"resultSet","connectionId":"aaaaaaaa-aaaa-aaaa-aaaa-aaaaaaaaaaaa","statementId":1164383384,"ownStatement":false,"signature":null,"firstFrame":null,"updateCount":1}]}
Так может кто-нибудь подсказать мне, что в моем подходе что-то не так? или любые другие способы подключения Apache Phoenix через классы php.
Привет вам просто нужно следить за вещами в вашем файле конфигурации hbase.
phoenix.connection.autoCommit = true для hbase-site.xml
Других решений пока нет …