Eclipse Community Forums: Newcomers » EclipseStore And Postgres Demo Application

Home » Newcomers » Newcomers » EclipseStore And Postgres Demo Application(EclipseStore And Postgres Demo Application)

Show: Today's Messages :: Show Polls :: Message Navigator

EclipseStore And Postgres Demo Application [message #1863589]

Wed, 14 February 2024 07:17

Snehal Pokharkar

Messages: 1
Registered: February 2024

Junior Member

Hi Team,
I am currently trying to perform basic operations like create,update,fetch and delete using eclipsestore and postgres.
These basic operations working fine.
To connect to postgres and create storage every time using below:
SqlFileSystem fileSystem = SqlFileSystem.New(SqlConnector.Caching(SqlProviderPostgres.New(dataSource)));
EmbeddedStorageManager storageManager = EmbeddedStorage.start(fileSystem.ensureDirectoryPath(name));

However if I start java application in multiple instances and try to add or update records to root and perform storeroot operation,facing below issue:

Caused by: org.postgresql.util.PSQLException: ERROR: duplicate key value violates unique constraint "UserDemo$channel_0_pk"
Detail: Key (identifier, start)=(channel_0_1.dat, 256280) already exists.
at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2532)
at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2267)
at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:312)
at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:448)
at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:369)
at org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:153)
at org.postgresql.jdbc.PgPreparedStatement.executeUpdate(PgPreparedStatement.java:119)
at org.eclipse.store.afs.sql.types.SqlConnector$Default.lambda$writeData$19(SqlConnector.java:902)
at org.eclipse.store.afs.sql.types.SqlProvider$Abstract.execute(SqlProvider.java:390)

I am unable to fetch latest storageManager and root content, before storing root. How to get latest storagemanger so that while storing data latest start and end values from User$channel_0 will be available and next offset value will be stored ?

Report message to a moderator