turso storage engine

Cargo.toml

@@ -157,7 +157,7 @@ tracing = "0.1"
 tracing-core = { version = "0.1" }
 tracing-opentelemetry = "0.29.0"
 tracing-subscriber = { version = "0.3", features = ["env-filter", "json"] }
-turso = "0.1.4"
+turso = { git = "https://github.com/tursodatabase/turso.git", tag = "v0.4.0-pre.14"}
 url = { version = "2.5.4", features = ["serde"] }
 uuid = { version = "1.13.2", features = ["serde", "v4", "v7"] }
 zstd = "0.13.2"

tansu-broker/tests/topic.rs

@@ -583,7 +583,6 @@ mod turso {
         .await
     }
 
-    #[ignore]
     #[tokio::test]
     async fn create_describe_topic_partitions_by_id() -> Result<()> {
         let _guard = init_tracing()?;
@@ -599,7 +598,6 @@ mod turso {
         .await
     }
 
-    #[ignore]
     #[tokio::test]
     async fn create_describe_topic_partitions_by_name() -> Result<()> {
         let _guard = init_tracing()?;
@@ -615,7 +613,6 @@ mod turso {
         .await
     }
 
-    #[ignore]
     #[tokio::test]
     async fn describe_non_existing_topic_partitions_by_name() -> Result<()> {
         let _guard = init_tracing()?;

tansu-storage/src/ddl/010-cluster.sql

@@ -13,7 +13,7 @@
 -- limitations under the License.
 
 create table if not exists cluster (
-    id integer primary key autoincrement,
+    id integer primary key autoincrement not null,
     name text not null unique,
     last_updated text default current_timestamp not null,
     created_at text default current_timestamp not null

tansu-storage/src/ddl/020-consumer-group.sql

@@ -13,8 +13,8 @@
 -- limitations under the License.
 
 create table if not exists consumer_group (
-    id integer primary key autoincrement,
-    cluster integer references cluster (id) not null,
+    id integer primary key autoincrement not null,
+    cluster integer references cluster (id),
     name text not null,
     last_updated text default current_timestamp not null,
     created_at text default current_timestamp not null,

tansu-storage/src/ddl/020-producer.sql

@@ -15,8 +15,8 @@
 -- non transactional idempotent producer
 --
 create table if not exists producer (
-    id integer primary key autoincrement,
-    cluster int references cluster (id) not null,
+    id integer primary key autoincrement not null,
+    cluster int references cluster (id),
     last_updated text default current_timestamp not null,
     created_at text default current_timestamp not null
 );

tansu-storage/src/ddl/020-topic.sql

@@ -13,8 +13,8 @@
 -- limitations under the License.
 
 create table if not exists topic (
-    id integer primary key autoincrement,
-    cluster int references cluster (id) not null,
+    id integer primary key autoincrement not null,
+    cluster int references cluster (id),
     name text not null,
     uuid text not null,
     partitions int not null,

tansu-storage/src/ddl/030-consumer-group-detail.sql

@@ -13,7 +13,7 @@
 -- limitations under the License.
 
 create table if not exists consumer_group_detail (
-    id integer primary key autoincrement,
+    id integer primary key autoincrement not null,
     consumer_group int references consumer_group (id) unique,
     e_tag text not null,
     detail text not null,

tansu-storage/src/ddl/030-producer-epoch.sql

@@ -13,7 +13,7 @@
 -- limitations under the License.
 
 create table if not exists producer_epoch (
-    id integer primary key autoincrement,
+    id integer primary key autoincrement not null,
     producer integer references producer (id),
     epoch integer default 0 not null,
     last_updated text default current_timestamp not null,

tansu-storage/src/ddl/030-topic-configuration.sql

@@ -13,7 +13,7 @@
 -- limitations under the License.
 
 create table if not exists topic_configuration (
-    id integer primary key autoincrement,
+    id integer primary key autoincrement not null,
     topic int references topic (id),
     name text not null,
     value text,

tansu-storage/src/ddl/030-topition.sql

@@ -13,7 +13,7 @@
 -- limitations under the License.
 
 create table if not exists topition (
-    id integer primary key autoincrement,
+    id integer primary key autoincrement not null,
     topic integer references topic (id),
     partition integer,
     last_updated text default current_timestamp not null,

tansu-storage/src/ddl/030-txn.sql

@@ -15,7 +15,7 @@
 -- transactional, including idempotent producer
 --
 create table if not exists txn (
-    id integer primary key autoincrement,
+    id integer primary key autoincrement not null,
     cluster integer references cluster (id),
     name text,
     producer integer references producer (id),

tansu-storage/src/ddl/040-consumer-offset.sql

@@ -13,7 +13,7 @@
 -- limitations under the License.
 
 create table if not exists consumer_offset (
-    id integer primary key autoincrement,
+    id integer primary key autoincrement not null,
     consumer_group integer references consumer_group (id),
     topition integer references topition (id),
     committed_offset integer,

tansu-storage/src/ddl/040-header.sql

@@ -13,7 +13,7 @@
 -- limitations under the License.
 
 create table if not exists header (
-    topition integer,
+    topition integer references topition (id),
     offset_id integer,
     k blob,
     v blob,

tansu-storage/src/ddl/040-producer-detail.sql

@@ -13,7 +13,7 @@
 -- limitations under the License.
 
 create table if not exists producer_detail (
-    id integer primary key autoincrement,
+    id integer primary key autoincrement not null,
     producer_epoch integer references producer_epoch (id),
     topition integer references topition (id),
     sequence integer default 0 not null,

tansu-storage/src/ddl/040-txn-detail.sql

@@ -13,7 +13,7 @@
 -- limitations under the License.
 
 create table if not exists txn_detail (
-    id integer primary key autoincrement,
+    id integer primary key autoincrement not null,
     "transaction" integer references txn (id),
     producer_epoch integer references producer_epoch (id),
     transaction_timeout_ms integer not null,

tansu-storage/src/ddl/040-watermark.sql

@@ -13,7 +13,7 @@
 -- limitations under the License.
 
 create table if not exists watermark (
-    id integer primary key autoincrement,
+    id integer primary key autoincrement not null,
     topition integer references topition (id),
     low integer,
     high integer,

tansu-storage/src/ddl/050-txn-offset-commit.sql

@@ -13,7 +13,7 @@
 -- limitations under the License.
 
 create table if not exists txn_offset_commit (
-    id integer primary key autoincrement,
+    id integer primary key autoincrement not null,
     txn_detail integer references txn_detail (id),
     consumer_group integer references consumer_group (id),
     generation_id integer,

tansu-storage/src/ddl/050-txn-topition.sql

@@ -15,7 +15,7 @@
 -- AddPartitionsToTxnRequest
 --
 create table if not exists txn_topition (
-    id integer primary key autoincrement,
+    id integer primary key autoincrement not null,
     txn_detail integer references txn_detail (id),
     topition integer references topition (id),
     last_updated text default current_timestamp not null,

tansu-storage/src/ddl/060-txn-offset-commit-tp.sql

@@ -13,7 +13,7 @@
 -- limitations under the License.
 
 create table if not exists txn_offset_commit_tp (
-    id integer primary key autoincrement,
+    id integer primary key autoincrement not null,
     offset_commit integer references txn_offset_commit (id),
     topition integer references topition (id),
     committed_offset integer,

tansu-storage/src/ddl/060-txn-produce-offset.sql

@@ -13,7 +13,7 @@
 -- limitations under the License.
 
 create table if not exists txn_produce_offset (
-    id integer primary key autoincrement,
+    id integer primary key autoincrement not null,
     txn_topition integer references txn_topition (id) unique,
     offset_start integer,
     offset_end integer,