hbase — Невозможно UPSERT записи в Apache Phoenix через переполнение стека

Я пытаюсь выбрать и UPSERT значение в Апач феникс от PHP Классы. я смогу select с помощью php curl запросить сервер, который установлен на порт 8765 Вроде у меня есть доля в примере.
Точно так же я пытаюсь вставить данные(UPSERT) в Фениксе с использованием PHP Curl. Это дает мне ответ, но данные не вставляются.

PHP

<?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.

1

Решение

Привет вам просто нужно следить за вещами в вашем файле конфигурации hbase.

phoenix.connection.autoCommit = true для hbase-site.xml

0

Другие решения

Других решений пока нет …

По вопросам рекламы [email protected]