Я исследую управление транзакциями в Apache Ignite и создал простой скрипт, который:
- Создает таблицу
- Получает количество строк
- Начинаетсятранзакция
- Вставка строки
- Получение количества строк
- Откат транзакции
- Получение количества строк
Шаги 1через 5 работает, как и ожидалось, но на шаге 6 не удается выполнить откат строки, вставленной на шаге 4, а количество строк на шаге 7 все еще равно 1.
Я понимаю, что для кеша / схемы требуется некоторая конфигурация, которая требуетбудет сделано, и мне интересно, если я ошибаюсь.Документация предполагает, что мне нужно использовать «TRANSACTIONAL_SNAPTSHOT» для режима атомарности.
«Кластер» имеет один узел.
Файл конфигурации Apache Ignite
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd">
<bean id="ignite.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
<property name="sqlSchemas">
<list>
<value>SAMPLE</value>
</list>
</property>
<!-- Enabling transactions for the "SAMPLE" cache/schema -->
<!-- See: https://apacheignite.readme.io/docs/transactions -->
<property name="cacheConfiguration">
<list>
<bean class="org.apache.ignite.configuration.CacheConfiguration">
<property name="name" value="SAMPLE"/>
<property name="atomicityMode" value="TRANSACTIONAL_SNAPSHOT"/>
<property name="backups" value="1"/>
</bean>
</list>
</property>
<!-- Enabling Apache Ignite Persistent Store. -->
<property name="dataStorageConfiguration">
<bean class="org.apache.ignite.configuration.DataStorageConfiguration">
<property name="defaultDataRegionConfiguration">
<bean class="org.apache.ignite.configuration.DataRegionConfiguration">
<property name="persistenceEnabled" value="true"/>
</bean>
</property>
</bean>
</property>
<!-- Explicitly configure TCP discovery SPI to provide a list of initial nodes. -->
<property name="discoverySpi">
<bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<!-- Uncomment static IP finder to enable static-based discovery of initial nodes. -->
<bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
<!-- <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder"> -->
<property name="addresses">
<list>
<!-- In distributed environment, replace with actual host IP address. -->
<value>10.0.1.217:47500</value>
</list>
</property>
</bean>
</property>
</bean>
</property>
</bean>
</beans>
Тестовый сценарий
from pyignite import Client
def get_rowcount(client):
result = client.sql('SELECT COUNT(*) FROM SAMPLE.T1')
row_count = next(result)[0]
return row_count
def main():
client = Client()
client.connect('ignite-host', 10800)
client.sql('CREATE TABLE IF NOT EXISTS SAMPLE.T1 (k int, v varchar, PRIMARY key(k))')
client.sql('DELETE SAMPLE.T1')
start_row_count = get_rowcount(client) # Expected row count = 0
client.sql("BEGIN TRANSACTION")
client.sql("INSERT INTO SAMPLE.T1 (k, v) values (1, 'Line 1')")
post_insert_row_count = get_rowcount(client) # Expected row count = 1
client.sql("ROLLBACK TRANSACTION")
end_row_count = get_rowcount(client) # Expected row count = 0, but is 1
client.close()
print('Start row count : {}'.format(start_row_count))
print('Post insert row count: {}'.format(post_insert_row_count))
print('End row count : {}'.format(end_row_count))
if __name__ == '__main__':
main()
Вывод сценария
Количество начальных строк: 0
Количество строк после вставки: 1
Количество строк в конце: 1