import utils.db_abstract
import basic.toolHandling
import utils.data_const as D
import basic.constants as B

class Entity:
    def __int__(self, job):
        self.job = job

    def createSchema(self):
        if B.TOPIC_NODE_DB in self.job.conf.confs:
            dbi = basic.toolHandling.getDbTool(self.job, None, self.job.conf.confs[B.TOPIC_NODE_DB][B.ATTR_TYPE])
        else:
            return "No DB in job-config"
        sql = self.getSchema()
        print(sql)
        for s in sql.split(";\n"):
            if len(s) < 3: continue
            dbi.execStatement(self.job.conf.confs[B.TOPIC_NODE_DB], s+";")

    def getSchema(self):
        raise Exception(B.EXCEPT_NOT_IMPLEMENT)

    def getHistoryFields(self):
        dbtype = self.job.conf.confs[B.TOPIC_NODE_DB][B.ATTR_TYPE]
        dbi = basic.toolHandling.getDbTool(self.job, None, dbtype)
        sql = dbi.getSchemaAttribut("inscommit", D.TYPE_STR)+","
        sql += dbi.getSchemaAttribut("insauthor", D.TYPE_STR)+","
        sql += dbi.getSchemaAttribut("instime", D.TYPE_TIME)+","
        sql += dbi.getSchemaAttribut("updcommit", D.TYPE_STR)+","
        sql += dbi.getSchemaAttribut("updauthor", D.TYPE_STR)+","
        sql += dbi.getSchemaAttribut("updtime", D.TYPE_TIME)+","
        sql += dbi.getSchemaAttribut("actual", D.TYPE_INT)
        return sql

    def getHistoryIndex(self, table):
        dbtype = self.job.conf.confs[B.TOPIC_NODE_DB][B.ATTR_TYPE]
        dbi = basic.toolHandling.getDbTool(self.job, None, dbtype)
        sql = dbi.getSchemaIndex(table, "actual") + "\n"
        return sql