io.odysz.semantic.syn

Class DBSyntableBuilder

java.lang.Object

io.odysz.transact.sql.Transcxt

io.odysz.semantic.DATranscxt

io.odysz.semantic.syn.DBSyntableBuilder

public class DBSyntableBuilder
extends DATranscxt

Sql statement builder for DBSyntext for handling database synchronization. Improved with temporary tables for broken network (and shutdown), concurrency and memory usage.

Author:

Ody

Nested Class Summary

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
protected SynchangeBuffMeta	exbm
HashMap<String,Nyquence>	nyquvect Nyquence vector [{synode, Nyquence}]
protected PeersMeta	pnvm
protected Nyquence	stamp
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
DBSyntableBuilder(String conn, String synodeId, SynodeMode mode)
DBSyntableBuilder(String conn, String synodeId, SynodeMode mode, SynChangeMeta chgm, SynodeMeta synm)

Method Summary

Modifier and Type	Method and Description
ExchangeBlock	abortExchange(ExessionPersist cx)
void	abortExchange(ExessionPersist cx, String target, ExchangeBlock rep)
ExchangeBlock	addMyChild(ExessionPersist ap, ExchangeBlock req, String org)
static HashMap<String,Object[]>	checkChangeCol(HashMap<String,Object[]> colnames) Check and extend column #ChangeFlag, which is for changing flag of change-logs.
protected void	cleanStaleSubs(String peer) Clean any subscriptions that should been accepted by the peer in the last session, but was not accutally accepted.
HashMap<String,Nyquence>	closeJoining(ExessionPersist cp, HashMap<String,Nyquence> clone)
ExchangeBlock	closexchange(ExessionPersist cx, ExchangeBlock rep)
protected io.odysz.transact.sql.Statement<?>	del0subchange(String iffnode) Delete change log if no subscribers accept.
int	deleteEntityBySynuid(SyntityMeta entm, String synuid)
String	domain()
ExchangeBlock	domainSignup(ExessionPersist app, String admin)
int	entities(SyntityMeta m)
SyntityMeta	getEntityMeta(String entbl)
SyntityMeta	getSyntityMeta(String tbl)
Nyquence	incN0(Nyquence... n) this.n0++, this.n0 = max(n0, maxn)
DBSyntableBuilder	incNyquence() Inc my n0, then reload from DB.
long	incSeq()
ExchangeBlock	initDomain(ExessionPersist cp, String admin, ExchangeBlock domainstatus)
ExchangeBlock	initExchange(ExessionPersist cp, String target) insert into exchanges select * from change_logs where n > nyquvect[target].n
String[]	insertEntity(SyntityMeta m, SynEntity e)
io.odysz.semantics.ISemantext	instancontxt(String conn, io.odysz.semantics.IUser usr) Create a new semantext instance with the static resources.
DBSyntableBuilder	loadNyquvect0(String conn)
Nyquence	n0()
protected DBSyntableBuilder	n0(Nyquence nyq)
void	onAbort(ExchangeBlock req)
ExchangeBlock	onclosexchange(ExessionPersist sx, ExchangeBlock rep)
ExchangeBlock	onInit(ExessionPersist sp, ExchangeBlock inireq) insert into exchanges select * from change_logs where n > nyquvect[sx.peer].n
void	onRequires(ExessionPersist cp, ExchangeBlock req)
protected Nyquence	persistamp()
protected Nyquence	persistamp(Nyquence n)
DBSyntableBuilder	registerEntity(String conn, SyntityMeta m)
ExchangeBlock	requirestore(ExessionPersist xp, String peer)
void	restorexchange() Client have found unfinished exchange session then retry it.
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 synuid, SyntityMeta entm, Object... nvs)

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

pnvm

protected PeersMeta pnvm

subm

protected SynSubsMeta subm

chgm

protected SynChangeMeta chgm

exbm

protected SynchangeBuffMeta exbm

stamp

protected Nyquence stamp

nyquvect

public HashMap<String,Nyquence> nyquvect

Nyquence vector [{synode, Nyquence}]

Constructor Detail

DBSyntableBuilder

public DBSyntableBuilder(String conn,
                         String synodeId,
                         SynodeMode mode)
                  throws SQLException,
                         SAXException,
                         IOException,
                         io.odysz.transact.x.TransException

Throws:

SQLException

SAXException

IOException

io.odysz.transact.x.TransException

DBSyntableBuilder

public DBSyntableBuilder(String conn,
                         String synodeId,
                         SynodeMode mode,
                         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()

persistamp

protected Nyquence persistamp(Nyquence n)
                       throws io.odysz.transact.x.TransException,
                              SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

persistamp

protected Nyquence persistamp()
                       throws io.odysz.transact.x.TransException,
                              SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

n0

public Nyquence n0()

n0

protected DBSyntableBuilder n0(Nyquence nyq)

domain

public String domain()

synrobot

public io.odysz.semantics.IUser synrobot()

incSeq

public long incSeq()

getSyntityMeta

public SyntityMeta getSyntityMeta(String tbl)

initExchange

public ExchangeBlock initExchange(ExessionPersist cp,
                                  String target)
                           throws io.odysz.transact.x.TransException,
                                  SQLException

insert into exchanges select * from change_logs where n > nyquvect[target].n

Parameters:

cp -

target -

Returns:

{total: change-logs to be exchanged}

Throws:

io.odysz.transact.x.TransException

SQLException

onInit

public ExchangeBlock onInit(ExessionPersist sp,
                            ExchangeBlock inireq)
                     throws SQLException,
                            io.odysz.transact.x.TransException

insert into exchanges select * from change_logs where n > nyquvect[sx.peer].n

Parameters:

sp -

inireq -

Returns:

response block

Throws:

io.odysz.transact.x.TransException

SQLException

abortExchange

public void abortExchange(ExessionPersist cx,
                          String target,
                          ExchangeBlock rep)

closexchange

public ExchangeBlock closexchange(ExessionPersist cx,
                                  ExchangeBlock rep)
                           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

abortExchange

public ExchangeBlock abortExchange(ExessionPersist cx)
                            throws io.odysz.transact.x.TransException,
                                   SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

onclosexchange

public ExchangeBlock onclosexchange(ExessionPersist sx,
                                    ExchangeBlock rep)
                             throws io.odysz.transact.x.TransException,
                                    SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

onAbort

public void onAbort(ExchangeBlock req)
             throws io.odysz.transact.x.TransException,
                    SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

requirestore

public ExchangeBlock requirestore(ExessionPersist xp,
                                  String peer)

onRequires

public void onRequires(ExessionPersist cp,
                       ExchangeBlock req)
                throws ExchangeException

Throws:

ExchangeException

restorexchange

public void restorexchange()

Client have found unfinished exchange session then retry it.

deleteEntityBySynuid

public int deleteEntityBySynuid(SyntityMeta entm,
                                String synuid)
                         throws io.odysz.transact.x.TransException,
                                SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

insertEntity

public String[] insertEntity(SyntityMeta m,
                             SynEntity e)
                      throws io.odysz.transact.x.TransException,
                             SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

updateEntity

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

Throws:

io.odysz.transact.x.TransException

SQLException

IOException

registerEntity

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

Throws:

SemanticException

io.odysz.transact.x.TransException

SQLException

getEntityMeta

public SyntityMeta getEntityMeta(String entbl)
                          throws SemanticException

Throws:

SemanticException

incNyquence

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

Inc my n0, then reload from DB.

Returns:

this

Throws:

io.odysz.transact.x.TransException

SQLException

incN0

public Nyquence incN0(Nyquence... n)
               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

loadNyquvect0

public DBSyntableBuilder loadNyquvect0(String conn)
                                throws SQLException,
                                       io.odysz.transact.x.TransException

Throws:

SQLException

io.odysz.transact.x.TransException

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

domainSignup

public ExchangeBlock domainSignup(ExessionPersist app,
                                  String admin)

initDomain

public ExchangeBlock initDomain(ExessionPersist cp,
                                String admin,
                                ExchangeBlock domainstatus)
                         throws io.odysz.transact.x.TransException,
                                SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

closeJoining

public HashMap<String,Nyquence> closeJoining(ExessionPersist cp,
                                             HashMap<String,Nyquence> clone)

cleanStaleSubs

protected void cleanStaleSubs(String peer)

Clean any subscriptions that should been accepted by the peer in the last session, but was not accutally accepted. Such case can be the peer node rejected data when no knowledge about the synoder.

Parameters:

peer -

del0subchange

protected io.odysz.transact.sql.Statement<?> del0subchange(String iffnode)
                                                    throws io.odysz.transact.x.TransException

Delete change log if no subscribers accept.

Parameters:

domain -

iffnode - delete the change-log iff the node, i.e. the subscriber, exists. For answers, it's the node himself, for challenge, it's the source node.

Returns:

the delete statement

Throws:

io.odysz.transact.x.TransException

checkChangeCol

public static HashMap<String,Object[]> checkChangeCol(HashMap<String,Object[]> colnames)

Check and extend column #ChangeFlag, which is for changing flag of change-logs.

Parameters:

answer -

Returns:

this

addMyChild

public ExchangeBlock addMyChild(ExessionPersist ap,
                                ExchangeBlock req,
                                String org)
                         throws io.odysz.transact.x.TransException,
                                SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

entities

public int entities(SyntityMeta m)
             throws SQLException,
                    io.odysz.transact.x.TransException

Throws:

SQLException

io.odysz.transact.x.TransException