Python Phoenixdb connection.commit () не работает - PullRequest
0 голосов
/ 25 октября 2018

Я использую Phoenix db.

Я хотел вставить данные в таблицу TABLE_A, в которой есть 100 строк.

Итак, я создалсначала соединение.

db_url = 'http://hostname:port/'
conn = phoenixdb.connect(db_url, autocommit=False)  # Setting autocommit=False
cursor = conn.cursor()

cursor.execute("UPSERT INTO TABLE_A VALUES (?,?,?,?,?,?)", t1)
conn.commit()  # comitting the db
conn.close()

Но когда я запускаю

select count(*) from TABLE_A;

Это все равно дает мне 100 .

Часть 2:

Теперь я создал новое соединение, на этот раз с autocommit = True.

conn = phoenixdb.connect(db_url, autocommit=True)
cursor = conn.cursor()

cursor.execute("UPSERT INTO TABLE_A VALUES (?,?,?,?,?,?)", t1)
conn.close()

Опять же, если я выполню оператор select count(*) ..., я получу 101 строки.

Не работает ли опция autommit = False и conn.commit () в phoenixdb?

Используемая версия: HBase 2.0.0.3.0.0.0-1634, Phoenix 5.0

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...