README
Tr
DynamicTableWriter
- ::is_editableFieldMeta::is_editable
- ::is_visibleFieldMeta::is_visible
- ::makeFieldMeta::make
- ::get_table_metaInMemoryMetaProvider::get_table_meta
- ::list_table_namesInMemoryMetaProvider::list_table_names
- ::newInMemoryMetaProvider::new
- ::registerInMemoryMetaProvider::register
- ::get_rowInMemoryTableWriter::get_row
- ::get_row_by_keyInMemoryTableWriter::get_row_by_key
- ::get_table_rowsInMemoryTableWriter::get_table_rows
- ::newInMemoryTableWriter::new
- ::from_strPersistMode::from_str
- ::as_interceptorPersistPostInterceptor::as_interceptor
- ::interceptPersistPostInterceptor::intercept
- ::makePersistPostInterceptor::make
- ::add_fieldTableMeta::add_field
- ::get_fieldTableMeta::get_field
- ::makeTableMeta::make
V
fill_system_fields
V
is_table_name_safe

jeeflow-persist

jeeflow dynamic table persist (DynamicTableWriter + PersistPostInterceptor + Meta)

Download zip

Author

mldong

Version

0.1.0

License

Apache-2.0

Repository

github.com/mldong/jeeflow-moon

Last updated

5 hours ago

Downloads

Dependencies

mldong/jeeflow-core0.1.0

#persist

jeeflow 工作流引擎 MoonBit 实现（第 7 语言）组件：业务数据动态入库：DynamicTableWriter + PersistPostInterceptor（ARCHIVE/SYNC）+ 元数据

详见仓根 README.md 与 docs/。

DynamicTableWriter

source

pub(open) trait DynamicTableWriter {
  fn insert(Self, String, Map[String, Json]) -> Int64 raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError
  fn update(Self, String, Int64, Map[String, Json]) -> Unit raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError
  fn exists(Self, String, Int64) -> Bool raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError
  fn exists_by_key(Self, String, String, Int64) -> Bool raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError
  fn update_by_key(Self, String, Map[String, Json], String, Int64) -> Unit raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError
  fn columns(Self, String, Array[String]) -> Array[String] raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError
}

DynamicTableWriter trait（MoonBit：大接口 trait 形态）

FieldMeta

source

pub(all) struct FieldMeta {
  column_name : String
  column_type : String
  display_name : String
  nullable : Bool
  default_value : String?
  permission : Int
}

字段元数据（动态表列）

FieldMeta::is_editable

source

fn FieldMeta::is_editable(self : FieldMeta) -> Bool

FieldMeta::is_visible

source

fn FieldMeta::is_visible(self : FieldMeta) -> Bool

FieldMeta::make

source

fn FieldMeta::make(column_name : String, column_type : String, display_name : String) -> FieldMeta

InMemoryMetaProvider

source

pub(all) struct InMemoryMetaProvider {
  tables : Map[String, TableMeta]
}

IDynamicMetaProvider 内存实现

InMemoryMetaProvider::get_table_meta

source

fn InMemoryMetaProvider::get_table_meta(self : InMemoryMetaProvider, table_name : String) -> TableMeta? raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

InMemoryMetaProvider::list_table_names

source

fn InMemoryMetaProvider::list_table_names(self : InMemoryMetaProvider) -> Array[String]

InMemoryMetaProvider::new

source

fn InMemoryMetaProvider::new() -> InMemoryMetaProvider

InMemoryMetaProvider::register

source

fn InMemoryMetaProvider::register(self : InMemoryMetaProvider, meta : TableMeta) -> Unit

InMemoryTableWriter

source

pub(all) struct InMemoryTableWriter {
  id_counter : Int64
  tables : Map[String, Map[Int64, Map[String, Json]]]
}

impl DynamicTableWriter for InMemoryTableWriter

fn columns(self : InMemoryTableWriter, _table_name : String, candidates : Array[String]) -> Array[String] raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

source

fn exists(self : InMemoryTableWriter, table_name : String, id : Int64) -> Bool raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

source

fn exists_by_key(self : InMemoryTableWriter, table_name : String, key : String, value : Int64) -> Bool raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

source

fn insert(self : InMemoryTableWriter, table_name : String, data : Map[String, Json]) -> Int64 raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

source

fn update(self : InMemoryTableWriter, table_name : String, id : Int64, data : Map[String, Json]) -> Unit raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

source

fn update_by_key(self : InMemoryTableWriter, table_name : String, data : Map[String, Json], key : String, value : Int64) -> Unit raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

source

InMemoryTableWriter::get_row

source

fn InMemoryTableWriter::get_row(self : InMemoryTableWriter, table_name : String, id : Int64) -> Map[String, Json]?

InMemoryTableWriter::get_row_by_key

source

fn InMemoryTableWriter::get_row_by_key(self : InMemoryTableWriter, table_name : String, key : String, value : Int64) -> Map[String, Json]?

InMemoryTableWriter::get_table_rows

source

fn InMemoryTableWriter::get_table_rows(self : InMemoryTableWriter, table_name : String) -> Array[Map[String, Json]]

InMemoryTableWriter::new

source

fn InMemoryTableWriter::new() -> InMemoryTableWriter

PersistMode

source

pub enum PersistMode {
  Archive
  Sync
} derive(Eq, Show)

持久化模式

PersistMode::from_str

source

fn PersistMode::from_str(s : String) -> PersistMode?

PersistPostInterceptor

source

pub(all) struct PersistPostInterceptor {
  meta_provider : InMemoryMetaProvider
  table_writer : &DynamicTableWriter
}

PersistPostInterceptor::as_interceptor

source

fn PersistPostInterceptor::as_interceptor(self : PersistPostInterceptor) -> @mldong/jeeflow-core/spi.InterceptorFn
InterceptorFn

装配为引擎拦截器（order=100，后置）

PersistPostInterceptor::intercept

source

fn PersistPostInterceptor::intercept(self : PersistPostInterceptor, exec : @mldong/jeeflow-core/exec.Execution
Execution) -> Unit raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

PersistPostInterceptor::make

source

fn PersistPostInterceptor::make(meta_provider : InMemoryMetaProvider, table_writer : &DynamicTableWriter) -> PersistPostInterceptor

TableMeta

source

pub(all) struct TableMeta {
  table_name : String
  display_name : String
  fields : Array[FieldMeta]
}

TableMeta::add_field

source

fn TableMeta::add_field(self : TableMeta, field : FieldMeta) -> Unit

TableMeta::get_field

source

fn TableMeta::get_field(self : TableMeta, column_name : String) -> FieldMeta?

TableMeta::make

source

fn TableMeta::make(table_name : String, display_name : String) -> TableMeta

fill_system_fields

source

fn fill_system_fields(data : Map[String, Json], operator : String, is_insert : Bool) -> Unit

系统字段填充（时间走 Clock 注入口，D-M0-3）

is_table_name_safe

source

fn is_table_name_safe(name : String) -> Bool

动态表名安全检查：仅字母数字下划线 + 保留前缀拒绝

Source Files

Site source Report issue Packages Build queue Skills Statistics

jeeflow-persist

#persist

#DynamicTableWriter

#FieldMeta

#FieldMeta::is_editable

#FieldMeta::is_visible

#FieldMeta::make

#InMemoryMetaProvider

#InMemoryMetaProvider::get_table_meta

#InMemoryMetaProvider::list_table_names

#InMemoryMetaProvider::new

#InMemoryMetaProvider::register

#InMemoryTableWriter

#InMemoryTableWriter::get_row

#InMemoryTableWriter::get_row_by_key

#InMemoryTableWriter::get_table_rows

#InMemoryTableWriter::new

#PersistMode

#PersistMode::from_str

#PersistPostInterceptor

#PersistPostInterceptor::as_interceptor

#PersistPostInterceptor::intercept

#PersistPostInterceptor::make

#TableMeta

#TableMeta::add_field

#TableMeta::get_field

#TableMeta::make

#fill_system_fields

#is_table_name_safe

Source Files

DynamicTableWriter

FieldMeta

FieldMeta::is_editable

FieldMeta::is_visible

FieldMeta::make

InMemoryMetaProvider

InMemoryMetaProvider::get_table_meta

InMemoryMetaProvider::list_table_names

InMemoryMetaProvider::new

InMemoryMetaProvider::register

InMemoryTableWriter

InMemoryTableWriter::get_row

InMemoryTableWriter::get_row_by_key

InMemoryTableWriter::get_table_rows

InMemoryTableWriter::new

PersistMode

PersistMode::from_str

PersistPostInterceptor

PersistPostInterceptor::as_interceptor

PersistPostInterceptor::intercept

PersistPostInterceptor::make

TableMeta

TableMeta::add_field

TableMeta::get_field

TableMeta::make

fill_system_fields

is_table_name_safe