From 4febedb1d2dead31eecf410255958c08a6da112c Mon Sep 17 00:00:00 2001 From: tripathyr Date: Wed, 27 Nov 2024 08:46:39 +0530 Subject: [PATCH] Update models.py This is MySQL version --- models.py | 418 +++++++++++++++++++++++++++--------------------------- 1 file changed, 211 insertions(+), 207 deletions(-) diff --git a/models.py b/models.py index f2ca6a4..52dffb9 100644 --- a/models.py +++ b/models.py @@ -1,4 +1,4 @@ -from sqlalchemy import Column, Integer, Float, String +from sqlalchemy import Column, BigInteger, Float, Text from sqlalchemy.ext.declarative import declarative_base TokenBase = declarative_base() @@ -7,343 +7,347 @@ ContinuosContractBase = declarative_base() SystemBase = declarative_base() LatestCacheBase = declarative_base() - class ActiveTable(TokenBase): __tablename__ = "activeTable" - id = Column('id', Integer, primary_key=True) - address = Column('address', String) - parentid = Column('parentid', Integer) - consumedpid = Column('consumedpid', String) + id = Column('id', BigInteger, primary_key=True) + address = Column('address', Text) + parentid = Column('parentid', BigInteger) + consumedpid = Column('consumedpid', Text) transferBalance = Column('transferBalance', Float) addressBalance = Column('addressBalance', Float) - orphaned_parentid = Column('orphaned_parentid', Integer) - blockNumber = Column('blockNumber', Integer) + orphaned_parentid = Column('orphaned_parentid', BigInteger) + blockNumber = Column('blockNumber', BigInteger) class ConsumedTable(TokenBase): __tablename__ = "consumedTable" - primaryKey = Column('primaryKey', Integer, primary_key=True) - id = Column('id', Integer) - address = Column('address', String) - parentid = Column('parentid', Integer) - consumedpid = Column('consumedpid', String) + primaryKey = Column('primaryKey', BigInteger, primary_key=True) + id = Column('id', BigInteger) + address = Column('address', Text) + parentid = Column('parentid', BigInteger) + consumedpid = Column('consumedpid', Text) transferBalance = Column('transferBalance', Float) addressBalance = Column('addressBalance', Float) - orphaned_parentid = Column('orphaned_parentid', Integer) - blockNumber = Column('blockNumber', Integer) + orphaned_parentid = Column('orphaned_parentid', BigInteger) + blockNumber = Column('blockNumber', BigInteger) class TransferLogs(TokenBase): __tablename__ = "transferlogs" - primary_key = Column('id', Integer, primary_key=True) - sourceFloAddress = Column('sourceFloAddress', String) - destFloAddress = Column('destFloAddress', String) + primary_key = Column('id', BigInteger, primary_key=True) + sourceFloAddress = Column('sourceFloAddress', Text) + destFloAddress = Column('destFloAddress', Text) transferAmount = Column('transferAmount', Float) - sourceId = Column('sourceId', Integer) - destinationId = Column('destinationId', Integer) - blockNumber = Column('blockNumber', Integer) - time = Column('time', Integer) - transactionHash = Column('transactionHash', String) + sourceId = Column('sourceId', BigInteger) + destinationId = Column('destinationId', BigInteger) + blockNumber = Column('blockNumber', BigInteger) + time = Column('time', BigInteger) + transactionHash = Column('transactionHash', Text) class TransactionHistory(TokenBase): __tablename__ = "transactionHistory" - primary_key = Column('id', Integer, primary_key=True) - sourceFloAddress = Column('sourceFloAddress', String) - destFloAddress = Column('destFloAddress', String) + primary_key = Column('id', BigInteger, primary_key=True) + sourceFloAddress = Column('sourceFloAddress', Text) + destFloAddress = Column('destFloAddress', Text) transferAmount = Column('transferAmount', Float) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) - time = Column('time', Integer) - transactionHash = Column('transactionHash', String) - blockchainReference = Column('blockchainReference', String) - jsonData = Column('jsonData', String) - transactionType = Column('transactionType', String) - parsedFloData = Column('parsedFloData', String) + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) + time = Column('time', BigInteger) + transactionHash = Column('transactionHash', Text) + blockchainReference = Column('blockchainReference', Text) + jsonData = Column('jsonData', Text) + transactionType = Column('transactionType', Text) + parsedFloData = Column('parsedFloData', Text) class TokenContractAssociation(TokenBase): __tablename__ = "tokenContractAssociation" - primary_key = Column('id', Integer, primary_key=True) - tokenIdentification = Column('tokenIdentification', String) - contractName = Column('contractName', String) - contractAddress = Column('contractAddress', String) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) - time = Column('time', Integer) - transactionHash = Column('transactionHash', String) - blockchainReference = Column('blockchainReference', String) - jsonData = Column('jsonData', String) - transactionType = Column('transactionType', String) - parsedFloData = Column('parsedFloData', String) + primary_key = Column('id', BigInteger, primary_key=True) + tokenIdentification = Column('tokenIdentification', Text) + contractName = Column('contractName', Text) + contractAddress = Column('contractAddress', Text) + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) + time = Column('time', BigInteger) + transactionHash = Column('transactionHash', Text) + blockchainReference = Column('blockchainReference', Text) + jsonData = Column('jsonData', Text) + transactionType = Column('transactionType', Text) + parsedFloData = Column('parsedFloData', Text) class ContractStructure(ContractBase): __tablename__ = "contractstructure" - id = Column('id', Integer, primary_key=True) - attribute = Column('attribute', String) - index = Column('index', Integer) - value = Column('value', String) + id = Column('id', BigInteger, primary_key=True) + attribute = Column('attribute', Text) + index = Column('index', BigInteger) + value = Column('value', Text) class ContractParticipants(ContractBase): __tablename__ = "contractparticipants" - id = Column('id', Integer, primary_key=True) - participantAddress = Column('participantAddress', String) + id = Column('id', BigInteger, primary_key=True) + participantAddress = Column('participantAddress', Text) tokenAmount = Column('tokenAmount', Float) - userChoice = Column('userChoice', String) - transactionHash = Column('transactionHash', String) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) + userChoice = Column('userChoice', Text) + transactionHash = Column('transactionHash', Text) + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) winningAmount = Column('winningAmount', Float) class ContractTransactionHistory(ContractBase): __tablename__ = "contractTransactionHistory" - primary_key = Column('id', Integer, primary_key=True) - transactionType = Column('transactionType', String) - transactionSubType = Column('transactionSubType', String) - sourceFloAddress = Column('sourceFloAddress', String) - destFloAddress = Column('destFloAddress', String) + primary_key = Column('id', BigInteger, primary_key=True) + transactionType = Column('transactionType', Text) + transactionSubType = Column('transactionSubType', Text) + sourceFloAddress = Column('sourceFloAddress', Text) + destFloAddress = Column('destFloAddress', Text) transferAmount = Column('transferAmount', Float) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) - time = Column('time', Integer) - transactionHash = Column('transactionHash', String) - blockchainReference = Column('blockchainReference', String) - jsonData = Column('jsonData', String) - parsedFloData = Column('parsedFloData', String) + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) + time = Column('time', BigInteger) + transactionHash = Column('transactionHash', Text) + blockchainReference = Column('blockchainReference', Text) + jsonData = Column('jsonData', Text) + parsedFloData = Column('parsedFloData', Text) class ContractDeposits(ContractBase): __tablename__ = "contractdeposits" - id = Column('id', Integer, primary_key=True) - depositorAddress = Column('depositorAddress', String) + id = Column('id', BigInteger, primary_key=True) + depositorAddress = Column('depositorAddress', Text) depositAmount = Column('depositAmount', Float) depositBalance = Column('depositBalance', Float) - expiryTime = Column('expiryTime', String) - unix_expiryTime = Column('unix_expiryTime', Integer) - status = Column('status', String) - transactionHash = Column('transactionHash', String) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) + expiryTime = Column('expiryTime', Text) + unix_expiryTime = Column('unix_expiryTime', BigInteger) + status = Column('status', Text) + transactionHash = Column('transactionHash', Text) + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) class ConsumedInfo(ContractBase): __tablename__ = "consumedinfo" - - id = Column('id', Integer, primary_key=True) - id_deposittable = Column('id_deposittable', Integer) - transactionHash = Column('transactionHash', String) - blockNumber = Column('blockNumber', Integer) + + id = Column('id', BigInteger, primary_key=True) + id_deposittable = Column('id_deposittable', BigInteger) + transactionHash = Column('transactionHash', Text) + blockNumber = Column('blockNumber', BigInteger) class ContractWinners(ContractBase): __tablename__ = "contractwinners" - id = Column('id', Integer, primary_key=True) - participantAddress = Column('participantAddress', String) + id = Column('id', BigInteger, primary_key=True) + participantAddress = Column('participantAddress', Text) winningAmount = Column('winningAmount', Float) - userChoice = Column('userChoice', String) - transactionHash = Column('transactionHash', String) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) - referenceTxHash = Column('referenceTxHash', String) - + userChoice = Column('userChoice', Text) + transactionHash = Column('transactionHash', Text) + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) + referenceTxHash = Column('referenceTxHash', Text) class ContractStructure2(ContinuosContractBase): __tablename__ = "contractstructure" - id = Column('id', Integer, primary_key=True) - attribute = Column('attribute', String) - index = Column('index', Integer) - value = Column('value', String) + id = Column('id', BigInteger, primary_key=True) + attribute = Column('attribute', Text) + index = Column('index', BigInteger) + value = Column('value', Text) class ContractParticipants2(ContinuosContractBase): __tablename__ = "contractparticipants" - id = Column('id', Integer, primary_key=True) - participantAddress = Column('participantAddress', String) + id = Column('id', BigInteger, primary_key=True) + participantAddress = Column('participantAddress', Text) tokenAmount = Column('tokenAmount', Float) - transactionHash = Column('transactionHash', String) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) + transactionHash = Column('transactionHash', Text) + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) class ContractDeposits2(ContinuosContractBase): __tablename__ = "contractdeposits" - id = Column('id', Integer, primary_key=True) - depositorAddress = Column('depositorAddress', String) + id = Column('id', BigInteger, primary_key=True) + depositorAddress = Column('depositorAddress', Text) depositAmount = Column('depositAmount', Float) - expiryTime = Column('expiryTime', String) - status = Column('status', String) - transactionHash = Column('transactionHash', String) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) + expiryTime = Column('expiryTime', Text) + status = Column('status', Text) + transactionHash = Column('transactionHash', Text) + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) class ContractTransactionHistory2(ContinuosContractBase): __tablename__ = "contractTransactionHistory" - primary_key = Column('id', Integer, primary_key=True) - transactionType = Column('transactionType', String) - transactionSubType = Column('transactionSubType', String) - sourceFloAddress = Column('sourceFloAddress', String) - destFloAddress = Column('destFloAddress', String) + primary_key = Column('id', BigInteger, primary_key=True) + transactionType = Column('transactionType', Text) + transactionSubType = Column('transactionSubType', Text) + sourceFloAddress = Column('sourceFloAddress', Text) + destFloAddress = Column('destFloAddress', Text) transferAmount = Column('transferAmount', Float) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) - time = Column('time', Integer) - transactionHash = Column('transactionHash', String) - blockchainReference = Column('blockchainReference', String) - jsonData = Column('jsonData', String) - parsedFloData = Column('parsedFloData', String) + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) + time = Column('time', BigInteger) + transactionHash = Column('transactionHash', Text) + blockchainReference = Column('blockchainReference', Text) + jsonData = Column('jsonData', Text) + parsedFloData = Column('parsedFloData', Text) class ActiveContracts(SystemBase): __tablename__ = "activecontracts" - id = Column('id', Integer, primary_key=True) - contractName = Column('contractName', String) - contractAddress = Column('contractAddress', String) - status = Column('status', String) - tokenIdentification = Column('tokenIdentification', String) - contractType = Column('contractType', String) - transactionHash = Column('transactionHash', String) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) - incorporationDate = Column('incorporationDate', String) - expiryDate = Column('expiryDate', String) - closeDate = Column('closeDate', String) + id = Column('id', BigInteger, primary_key=True) + contractName = Column('contractName', Text) + contractAddress = Column('contractAddress', Text) + status = Column('status', Text) + tokenIdentification = Column('tokenIdentification', Text) + contractType = Column('contractType', Text) + transactionHash = Column('transactionHash', Text) + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) + incorporationDate = Column('incorporationDate', Text) + expiryDate = Column('expiryDate', Text) + closeDate = Column('closeDate', Text) class SystemData(SystemBase): __tablename__ = "systemData" - id = Column('id', Integer, primary_key=True) - attribute = Column('attribute', String) - value = Column('value', String) - + id = Column('id', BigInteger, primary_key=True) + attribute = Column('attribute', Text) + value = Column('value', Text) class ContractAddressMapping(SystemBase): __tablename__ = "contractAddressMapping" - id = Column('id', Integer, primary_key=True) - address = Column('address', String) - addressType = Column('addressType', String) - contractName = Column('contractName', String) - contractAddress = Column('contractAddress', String) + id = Column('id', BigInteger, primary_key=True) + address = Column('address', Text) + addressType = Column('addressType', Text) + contractName = Column('contractName', Text) + contractAddress = Column('contractAddress', Text) tokenAmount = Column('tokenAmount', Float) - transactionHash = Column('transactionHash', String) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) - + transactionHash = Column('transactionHash', Text) + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) class TokenAddressMapping(SystemBase): __tablename__ = "tokenAddressMapping" - id = Column('id', Integer, primary_key=True) - tokenAddress = Column('tokenAddress', String) - token = Column('token', String) - transactionHash = Column('transactionHash', String) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) - + id = Column('id', BigInteger, primary_key=True) + tokenAddress = Column('tokenAddress', Text) + token = Column('token', Text) + transactionHash = Column('transactionHash', Text) + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) class DatabaseTypeMapping(SystemBase): __tablename__ = "databaseTypeMapping" - id = Column('id', Integer, primary_key=True) - db_name = Column('db_name', String) - db_type = Column('db_type', String) - keyword = Column('keyword', String) - object_format = Column ('object_format', String) - blockNumber = Column('blockNumber', Integer) + id = Column('id', BigInteger, primary_key=True) + db_name = Column('db_name', Text) + db_type = Column('db_type', Text) + keyword = Column('keyword', Text) + object_format = Column('object_format', Text) + blockNumber = Column('blockNumber', BigInteger) class TimeActions(SystemBase): __tablename__ = "time_actions" - id = Column('id', Integer, primary_key=True) - time = Column('time', String) - activity = Column('activity', String) - status = Column('status', String) - contractName = Column('contractName', String) - contractAddress = Column('contractAddress', String) - contractType = Column('contractType', String) - tokens_db = Column('tokens_db', String) - parsed_data = Column('parsed_data', String) - transactionHash = Column('transactionHash', String) - blockNumber = Column('blockNumber', Integer) + id = Column('id', BigInteger, primary_key=True) + time = Column('time', Text) + activity = Column('activity', Text) + status = Column('status', Text) + contractName = Column('contractName', Text) + contractAddress = Column('contractAddress', Text) + contractType = Column('contractType', Text) + tokens_db = Column('tokens_db', Text) + parsed_data = Column('parsed_data', Text) + transactionHash = Column('transactionHash', Text) + blockNumber = Column('blockNumber', BigInteger) class RejectedContractTransactionHistory(SystemBase): __tablename__ = "rejectedContractTransactionHistory" - primary_key = Column('id', Integer, primary_key=True) - transactionType = Column('transactionType', String) - transactionSubType = Column('transactionSubType', String) - contractName = Column('contractName', String) - contractAddress = Column('contractAddress', String) - sourceFloAddress = Column('sourceFloAddress', String) - destFloAddress = Column('destFloAddress', String) + primary_key = Column('id', BigInteger, primary_key=True) + transactionType = Column('transactionType', Text) + transactionSubType = Column('transactionSubType', Text) + contractName = Column('contractName', Text) + contractAddress = Column('contractAddress', Text) + sourceFloAddress = Column('sourceFloAddress', Text) + destFloAddress = Column('destFloAddress', Text) transferAmount = Column('transferAmount', Float) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) - time = Column('time', Integer) - transactionHash = Column('transactionHash', String) - blockchainReference = Column('blockchainReference', String) - jsonData = Column('jsonData', String) - rejectComment = Column('rejectComment', String) - parsedFloData = Column('parsedFloData', String) + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) + time = Column('time', BigInteger) + transactionHash = Column('transactionHash', Text) + blockchainReference = Column('blockchainReference', Text) + jsonData = Column('jsonData', Text) + rejectComment = Column('rejectComment', Text) + parsedFloData = Column('parsedFloData', Text) class RejectedTransactionHistory(SystemBase): __tablename__ = "rejectedTransactionHistory" - primary_key = Column('id', Integer, primary_key=True) - tokenIdentification = Column('tokenIdentification', String) - sourceFloAddress = Column('sourceFloAddress', String) - destFloAddress = Column('destFloAddress', String) + primary_key = Column('id', BigInteger, primary_key=True) + tokenIdentification = Column('tokenIdentification', Text) + sourceFloAddress = Column('sourceFloAddress', Text) + destFloAddress = Column('destFloAddress', Text) transferAmount = Column('transferAmount', Float) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) - time = Column('time', Integer) - transactionHash = Column('transactionHash', String) - blockchainReference = Column('blockchainReference', String) - jsonData = Column('jsonData', String) - rejectComment = Column('rejectComment', String) - transactionType = Column('transactionType', String) - parsedFloData = Column('parsedFloData', String) - + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) + time = Column('time', BigInteger) + transactionHash = Column('transactionHash', Text) + blockchainReference = Column('blockchainReference', Text) + jsonData = Column('jsonData', Text) + rejectComment = Column('rejectComment', Text) + transactionType = Column('transactionType', Text) + parsedFloData = Column('parsedFloData', Text) class LatestTransactions(LatestCacheBase): __tablename__ = "latestTransactions" - - id = Column('id', Integer, primary_key=True) - transactionHash = Column('transactionHash', String) - blockNumber = Column('blockNumber', Integer) - jsonData = Column('jsonData', String) - transactionType = Column('transactionType', String) - parsedFloData = Column('parsedFloData', String) - db_reference = Column('db_reference', String) + + id = Column('id', BigInteger, primary_key=True) + transactionHash = Column('transactionHash', Text) + blockNumber = Column('blockNumber', BigInteger) + jsonData = Column('jsonData', Text) + transactionType = Column('transactionType', Text) + parsedFloData = Column('parsedFloData', Text) + db_reference = Column('db_reference', Text) class LatestBlocks(LatestCacheBase): __tablename__ = "latestBlocks" - id = Column('id', Integer, primary_key=True) - blockNumber = Column('blockNumber', Integer) - blockHash = Column('blockHash', String) - jsonData = Column('jsonData', String) + id = Column('id', BigInteger, primary_key=True) + blockNumber = Column('blockNumber', BigInteger) + blockHash = Column('blockHash', Text) + jsonData = Column('jsonData', Text) + + +class RecentBlocks(LatestCacheBase): + __tablename__ = "RecentBlocks" + + id = Column(BigInteger, primary_key=True, autoincrement=True) + blockNumber = Column(BigInteger, unique=True, nullable=False) + blockHash = Column(Text, nullable=False) + +