Advanced visibility for SQLite

temporalio · Feb 3, 2023 · 42950d8 · 42950d8
1 parent e43e5b5
commit 42950d8
Show file tree

Hide file tree

Showing 7 changed files with 427 additions and 207 deletions.
diff --git a/common/persistence/sql/sqlplugin/sqlite/plugin.go b/common/persistence/sql/sqlplugin/sqlite/plugin.go
@@ -204,5 +204,7 @@ func buildDSNAttr(cfg *config.SQL) (url.Values, error) {
 		// assume pragma
 		parameters.Add("_pragma", fmt.Sprintf("%s=%s", key, value))
 	}
+	// set time format
+	parameters.Add("_time_format", "sqlite")
 	return parameters, nil
 }
diff --git a/common/persistence/sql/sqlplugin/sqlite/typeconv.go b/common/persistence/sql/sqlplugin/sqlite/typeconv.go
@@ -47,7 +47,7 @@ func (c *converter) ToSQLiteDateTime(t time.Time) time.Time {
 	if t.IsZero() {
 		return minSQLiteDateTime
 	}
-	return t.UTC()
+	return t.UTC().Truncate(time.Microsecond)
 }
 
 // FromSQLiteDateTime converts SQLite datetime and returns go time