io.odysz.semantic.syn

Class DBSynsactBuilder

java.lang.Object

io.odysz.transact.sql.Transcxt

io.odysz.semantic.DATranscxt

io.odysz.semantic.syn.DBSynsactBuilder

public class DBSynsactBuilder
extends DATranscxt

Sql statement builder for DBSyntext for handling database synchronization.

Author:

Ody

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DBSynsactBuilder.SynmanticsMap

Nested classes/interfaces inherited from class io.odysz.semantic.DATranscxt

DATranscxt.SemanticsMap, DATranscxt.SmapFactory<M extends DATranscxt.SemanticsMap>

Field Summary

Fields

Modifier and Type	Field and Description
protected SynChangeMeta	chgm
static int	leafmode
protected HashMap<String,Nyquence>	nyquvect Nyquence vector [{synode, Nyquence}]
static int	peermode
protected PeersMeta	pnvm
protected SynSubsMeta	subm
protected SynodeMeta	synm

Fields inherited from class io.odysz.semantic.DATranscxt

cfgroot, dummy, runtimepath, smtMaps

Fields inherited from class io.odysz.transact.sql.Transcxt

basictx

Constructor Summary

Constructors

Constructor and Description
DBSynsactBuilder(String conn, String synodeId, String syndomain, int nodemode)
DBSynsactBuilder(String conn, String synodeId, String syndomain, int nodemode, SynChangeMeta chgm, SynodeMeta synm)

Method Summary

Modifier and Type	Method and Description
ChangeLogs	ackExchange(ExchangeContext x, ChangeLogs answer, String sn) Client node acknowledge destionation's response (from server), i.e.
ChangeLogs	addChild(ExchangeContext x, String childId, SynodeMode reqmode, io.odysz.semantics.IUser robot, String org, String domain) A hub node uses this to setup change logs for joining nodes.
HashMap<String,Nyquence>	closeJoining(ExchangeContext x, String sn, HashMap<String,Nyquence> nv)
HashMap<String,Nyquence>	closexchange(ExchangeContext x, String sn, HashMap<String,Nyquence> nv)
String	domain()
AnResultset	entities(SyntityMeta phm, String connId, io.odysz.semantics.IUser usr)
SyntityMeta	getEntityMeta(String entbl)
Nyquence	incN0(long maxn) this.n0++, this.n0 = max(n0, maxn)
Nyquence	incN0(Nyquence n)
DBSynsactBuilder	incNyquence() Inc my n0, then reload from DB.
protected ChangeLogs	initChallenges(ExchangeContext x, String peer)
ChangeLogs	initDomain(ExchangeContext x, ChangeLogs domainstatus)
<T extends SynEntity> ChangeLogs	initExchange(ExchangeContext x, String target, HashMap<String,Nyquence> nv) Find if there are change logs such that chg.n > myvect[remote].n, to be exchanged.
io.odysz.semantics.ISemantext	instancontxt(String conn, io.odysz.semantics.IUser usr) Create a new semantext instance with the static resources.
protected Nyquence	n0()
protected DBSynsactBuilder	n0(Nyquence nyq)
HashMap<String,Nyquence>	onAck(ExchangeContext x, ChangeLogs ack, String target, HashMap<String,Nyquence> srcnv, SyntityMeta entm) Commit buffered answer's changes as client node acknowledged the answers with ack.
void	oncloseJoining(ExchangeContext x, String sn, HashMap<String,Nyquence> nv)
void	onclosexchange(ExchangeContext x, String sn, HashMap<String,Nyquence> nv)
<T extends SynEntity> ChangeLogs	onExchange(ExchangeContext x, String from, HashMap<String,Nyquence> remotv, ChangeLogs req)
ChangeLogs	onJoining(SynodeMode reqmode, String joining, String domain, String org)
DBSynsactBuilder	registerEntity(String conn, SyntityMeta m)
String	synconn() Get synchronization meta connection id.
protected String	synode()
io.odysz.semantics.IUser	synrobot()
protected HashMap<String,Nyquence>	synyquvectMax(String peer, HashMap<String,Nyquence> nv, HashMap<String,Nyquence> mynv)
String	updateEntity(String synoder, String pid, SyntityMeta entm, Object... nvs) Syntity table updating.

Methods inherited from class io.odysz.semantic.DATranscxt

configRoot, delete, dummyUser, exists, findResulved, getBasicTrans, getHandler, getSysConnId, hasSemantics, initConfigs, insert, key, key, loadSemantics, now, quotation, select, tableMeta, update

Methods inherited from class io.odysz.transact.sql.Transcxt

basictx, delete, insert, insertExp, select, selectPage, selectPage, tableMeta, update, with, with

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

synm

protected SynodeMeta synm

subm

protected SynSubsMeta subm

chgm

protected SynChangeMeta chgm

pnvm

protected PeersMeta pnvm

peermode

public static final int peermode

See Also:

Constant Field Values

leafmode

public static final int leafmode

See Also:

Constant Field Values

nyquvect

protected HashMap<String,Nyquence> nyquvect

Nyquence vector [{synode, Nyquence}]

Constructor Detail

DBSynsactBuilder

public DBSynsactBuilder(String conn,
                        String synodeId,
                        String syndomain,
                        int nodemode)
                 throws SQLException,
                        SAXException,
                        IOException,
                        io.odysz.transact.x.TransException

Throws:

SQLException

SAXException

IOException

io.odysz.transact.x.TransException

DBSynsactBuilder

public DBSynsactBuilder(String conn,
                        String synodeId,
                        String syndomain,
                        int nodemode,
                        SynChangeMeta chgm,
                        SynodeMeta synm)
                 throws SQLException,
                        SAXException,
                        IOException,
                        io.odysz.transact.x.TransException

Throws:

SQLException

SAXException

IOException

io.odysz.transact.x.TransException

Method Detail

synconn

public String synconn()

Get synchronization meta connection id.

Returns:

conn-id

synode

protected String synode()

n0

protected Nyquence n0()

n0

protected DBSynsactBuilder n0(Nyquence nyq)

domain

public String domain()

synrobot

public io.odysz.semantics.IUser synrobot()

incNyquence

public DBSynsactBuilder incNyquence()
                             throws io.odysz.transact.x.TransException,
                                    SQLException

Inc my n0, then reload from DB.

Returns:

this

Throws:

io.odysz.transact.x.TransException

SQLException

instancontxt

public io.odysz.semantics.ISemantext instancontxt(String conn,
                                                  io.odysz.semantics.IUser usr)
                                           throws io.odysz.transact.x.TransException

Description copied from class: DATranscxt

Create a new semantext instance with the static resources.

DATranscxt use a basic context (without semantics handler) for basic sql building.
Every context used for DASemantics handling must use this to create a new context instance.

Overrides:

instancontxt in class DATranscxt

Parameters:

conn - connection id usually mapped with client function uri, like: Connects.uri2conn(req.uri())

Returns:

semantext

Throws:

io.odysz.transact.x.TransException

See Also:

ISemantext

entities

public AnResultset entities(SyntityMeta phm,
                            String connId,
                            io.odysz.semantics.IUser usr)
                     throws io.odysz.transact.x.TransException,
                            SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

getEntityMeta

public SyntityMeta getEntityMeta(String entbl)
                          throws SemanticException

Throws:

SemanticException

registerEntity

public DBSynsactBuilder registerEntity(String conn,
                                       SyntityMeta m)
                                throws SemanticException,
                                       io.odysz.transact.x.TransException,
                                       SQLException

Throws:

SemanticException

io.odysz.transact.x.TransException

SQLException

incN0

public Nyquence incN0(long maxn)
               throws io.odysz.transact.x.TransException,
                      SQLException

this.n0++, this.n0 = max(n0, maxn)

Parameters:

maxn -

Returns:

n0

Throws:

SQLException

io.odysz.transact.x.TransException

incN0

public Nyquence incN0(Nyquence n)
               throws io.odysz.transact.x.TransException,
                      SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

initExchange

public <T extends SynEntity> ChangeLogs initExchange(ExchangeContext x,
                                                     String target,
                                                     HashMap<String,Nyquence> nv)
                                              throws io.odysz.transact.x.TransException,
                                                     SQLException

Find if there are change logs such that chg.n > myvect[remote].n, to be exchanged.

Type Parameters:

T -

Parameters:

cx -

target - exchange target (server)

nv - nyquevect from target

Returns:

logs such that chg.n > nyv[target], i.e there are change logs to be exchanged.

Throws:

SQLException

io.odysz.transact.x.TransException

initChallenges

protected ChangeLogs initChallenges(ExchangeContext x,
                                    String peer)
                             throws SecurityException,
                                    io.odysz.transact.x.TransException,
                                    SQLException

Throws:

SecurityException

io.odysz.transact.x.TransException

SQLException

onExchange

public <T extends SynEntity> ChangeLogs onExchange(ExchangeContext x,
                                                   String from,
                                                   HashMap<String,Nyquence> remotv,
                                                   ChangeLogs req)
                                            throws SQLException,
                                                   io.odysz.transact.x.TransException

Throws:

SQLException

io.odysz.transact.x.TransException

ackExchange

public ChangeLogs ackExchange(ExchangeContext x,
                              ChangeLogs answer,
                              String sn)
                       throws SQLException,
                              io.odysz.transact.x.TransException,
                              IOException

Client node acknowledge destionation's response (from server), i.e. check answers up to n = my-n0 If there is no more challenges, increase my.n0.

Parameters:

x - exchange execution instance

answer -

sn -

Returns:

acknowledge, answer to the destination node's commitment, and have be committed at source.

Throws:

SQLException

io.odysz.transact.x.TransException

IOException

onAck

public HashMap<String,Nyquence> onAck(ExchangeContext x,
                                      ChangeLogs ack,
                                      String target,
                                      HashMap<String,Nyquence> srcnv,
                                      SyntityMeta entm)
                               throws SQLException,
                                      io.odysz.transact.x.TransException

Commit buffered answer's changes as client node acknowledged the answers with ack.

Parameters:

x - exchange execution's instance

ack - answer to previous challenge

target -

srcnv -

entm -

Returns:

nyquvect

Throws:

io.odysz.transact.x.TransException

SQLException

closexchange

public HashMap<String,Nyquence> closexchange(ExchangeContext x,
                                             String sn,
                                             HashMap<String,Nyquence> nv)
                                      throws io.odysz.transact.x.TransException,
                                             SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

synyquvectMax

protected HashMap<String,Nyquence> synyquvectMax(String peer,
                                                 HashMap<String,Nyquence> nv,
                                                 HashMap<String,Nyquence> mynv)
                                          throws io.odysz.transact.x.TransException,
                                                 SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

closeJoining

public HashMap<String,Nyquence> closeJoining(ExchangeContext x,
                                             String sn,
                                             HashMap<String,Nyquence> nv)
                                      throws io.odysz.transact.x.TransException,
                                             SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

onclosexchange

public void onclosexchange(ExchangeContext x,
                           String sn,
                           HashMap<String,Nyquence> nv)
                    throws SQLException,
                           io.odysz.transact.x.TransException

Throws:

SQLException

io.odysz.transact.x.TransException

oncloseJoining

public void oncloseJoining(ExchangeContext x,
                           String sn,
                           HashMap<String,Nyquence> nv)
                    throws SQLException,
                           io.odysz.transact.x.TransException

Throws:

SQLException

io.odysz.transact.x.TransException

addChild

public ChangeLogs addChild(ExchangeContext x,
                           String childId,
                           SynodeMode reqmode,
                           io.odysz.semantics.IUser robot,
                           String org,
                           String domain)
                    throws io.odysz.transact.x.TransException,
                           SQLException

A hub node uses this to setup change logs for joining nodes.

Parameters:

x -

childId -

robot -

org -

domain -

Returns:

{session: changeId, uids: "My-id,applyid"}

Throws:

io.odysz.transact.x.TransException

SQLException

onJoining

public ChangeLogs onJoining(SynodeMode reqmode,
                            String joining,
                            String domain,
                            String org)
                     throws io.odysz.transact.x.TransException,
                            SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

initDomain

public ChangeLogs initDomain(ExchangeContext x,
                             ChangeLogs domainstatus)
                      throws SQLException,
                             io.odysz.transact.x.TransException

Throws:

SQLException

io.odysz.transact.x.TransException

updateEntity

public String updateEntity(String synoder,
                           String pid,
                           SyntityMeta entm,
                           Object... nvs)
                    throws io.odysz.transact.x.TransException,
                           SQLException,
                           io.odysz.anson.x.AnsonException,
                           IOException

Syntity table updating. Synchronized entity table can only be updated with a pk condition.

Parameters:

entm -

pid -

field -

nvs - name-value pairs

Returns:

Throws:

io.odysz.transact.x.TransException

SQLException

IOException

io.odysz.anson.x.AnsonException