Guidelines

import idv.mikelue.jdut.datagrain.DataGrain;

DataGrain dataGrainByDefine = DataGrain.build(
	/**
	 * Defines the table meta-data
	 * The columns would be indexed by sequence of builds
	 */
	tableSchemaBuilder -> {
		tableSchemaBuilder
			.name("tab_1") // Mandatory
			.keys("col_1", "col_2"); // Used by DELETE operation
	},
	// :~)
	/**
	 * Adds the data of table
	 */
	rowsBuilder -> {
		rowsBuilder.implicitColumns(
			"col_1", "col_2", "col_3", "col_4"
		)
		/**
		 * Implicit data
		 */
		.addValues(10, "CC-1", () -> "AC-2", null)
		.addValues(11, "CC-1", () -> "AC-2", null)
		// :~)
		/**
		 * Explicit data
		 */
		.addFields(
			rowsBuilder.newField("col_1", 12),
			rowsBuilder.newField("col_2", 13),
			rowsBuilder.newField("col_3", () -> "AN-78")
			rowsBuilder.newField("col_4", () -> "AN-78")
		);
		// :~)
	}
	// :~)
);

import guru.mikelue.jdut.DataConductor;
import guru.mikelue.jdut.operation.DefaultOperators;

/**
 * dataSource - The initialized data source
 *
 * This conductor would load schema of database to complement the complete information of column.
 */
DataConductor dataConductor = DataConductor.build(dataSource);

/**
 * Executes the "INSERT"(defined in OperatorFactory) with data grain
 */
dataConductor.conduct(dataGrainByDefine, operatorFactory.get(DefaultOperators.INSERT));

import guru.mikelue.jdut.datagrain.DataGrain;

// dg_1 - The object of DataGrain
// dg_2 - Another object of DataGrain

// The data of dg_1 with data of dg_2....
DataGrain aggregatedDataGrains = dg_1.aggregate(dg_2);

// dataSource - The initialized data source

YamlConductorFactory yamlConductor = YamlConductorFactory.build(
	dataSource,
	builder -> builder
		// The factory of operator
		.operatorFactory(defaultOperationFactory)
		// The optional file loader for convertion string of file name to InputStream or Reader
		.resourceLoader((fileName) -> new FileReader(fileName))
		.namedOperator(
			"INSERT_AND_CHECK",
			(connection, dataRows) -> { /* Your database operations */ }
		)
		.namedDecorator(
			"[V1]",
			(dataRowBuilder) -> { /* Your data decoration */ }
		)
		.namedJdbcFunction(
			"func_1",
			connection -> { /* Your code of JDBC */ }
		)
);

import guru.mikelue.jdut.DuetConductor;

DuetConductor testConductor_1 = yamlFactory.conductNamedResource(
	"org/your/package/CarDaoTest-addNew.yaml",
	/**
	 * You could overrides configuration of YamlConductorFactory
	 */
	configure -> configure
		.namedDecorator("add_value", your_decorator)
	// :~)
);

// Consturct a content of YAML with Yaml.DEFAULT_TAGS directly(instead of file)
DuetConductor testConductor_2 = yamlConductor.conduct(
   YamlTags.DEFAULT_TAGS +
   "---\n" +
   "- !sql!table tab_1: {" +
   "  col_1: 40, col_2: \"VGA-1\"" +
   "}"
);

import guru.mikelue.jdut.operation.DefaultOperatorFactory;
import guru.mikelue.jdut.operation.DefaultOperators;

DefaultOperatorFactory factory = DefaultDataOperatorFactory.build(
	dataSource, builder -> {}
);

dataConductor.conduct(
	factory.get(DefaultOperators.INSERT),
	dataGrain
);

Connection conn = ConductorContext.getCurrentConnection()
	.orElseThrow(() -> new Exception("NoContext"));

/* 1) Use of connection */
/* 2) Do not close it!! */

import guru.mikelue.jdut.operation.DefaultOperatorFactory;
import guru.mikelue.jdut.operation.OperatorFactory;

// dataSource - The initialized data source
// yourMapOfOperators - Your customized mapping of operators
OperatorFactory yourFactory = DefaultOperatorFactory.build(
	dataSource,
	builder -> builder
		.add(
			metaData -> metaData.getDriverName().contains("something"),
			yourMapOfOperators
		)
);