Я использую 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