Dev commit: SQLite element

Author: hANSIc99

TODOS

@@ -1,32 +1,45 @@
 General:
 
 Documentation:
- When an element returns None, subsequent
- elements are still triggered
+
+ Terms:
+ Configuration Data: Parameters passed over the GUI by the user
+ Input Data: Data which is forwarded from other elements
+
+ General behaviour:
+ When an element returns None, subsequent
+ elements are still triggered
 
  Exceptions:
- Elements should throw an exception when configuration
- data is missing or cannot be processed
 
- Elements should try to handle all possible exceptions internally
- and only throw unhandled exceptions
+ #1
+ Elements should throw an exception when configuration
+ data is missing or cannot be processed
+
+ #2
+ Elements should try to handle all possible exceptions internally
+ and only throw critical exceptions.
+
+ #3
+ If appropriate, the result of a operation (if successfull or not) should
+ be forwarded to subsequent elements in order to react to
+ a possible unsuccesfull operation. When it was not possible to process the input data, return the PythonicError with related information.
+ Combine this with logging.warning (preferred) or logging.error.
 
- The result of a operation (if successfull or not) should
- be forwarded to subsequent elements in order to react to
- a possible unsuccesfull operation
+ #4
+ Avoid to use logging.error or logging.warning without the other mechanisms as those methods will only write to the log.
 
- When input data is required to perform some task and it
- is missing, elements should pass this information to subsequent elements
- and not throw an exception.d
 
+Check exception rules
 
-CCXT Method: Remove large if-else areas for parsing config
+CCXT Method: Try to optimize large if-else areas for parsing config
 
 Python: Add type hints
 
 Check if the 'inline'-keyword can be applied to some loops
 (page 146 C++ Der Programmierer)
 
+Telegram: Return error element when chat id is removed?
 
 Elementeditor:
 Add the possibility to pass arbitrary number of keyword arguments or

examples/generic_pipe_0e7b8360.py

@@ -0,0 +1,52 @@
+import time, queue
+from random import randrange
+try:
+ from element_types import Record, Function, ProcCMD, GuiCMD
+except ImportError: 
+ from Pythonic.element_types import Record, Function, ProcCMD, GuiCMD
+ 
+class Element(Function):
+
+ def __init__(self, id, config, inputData, return_queue, cmd_queue):
+ super().__init__(id, config, inputData, return_queue, cmd_queue)
+
+
+ def execute(self):
+
+
+ #####################################
+ # #
+ # REFERENCE IMPLEMENTATION #
+ # #
+ #####################################
+
+
+ # list all tables
+ # SELECT name FROM sqlite_master WHERE type='table'
+
+ # create table of not exist
+ # CREATE TABLE IF NOT EXISTS my_table (timestamp INTEGER PRIMARY KEY NOT NULL, value UNSIGNED BIG INT);
+
+ # insert into table
+ # INSERT INTO my_table VALUES (?, ?)
+ # 
+ # epoch in seconds: int(timer.time())
+ # random int: randrange(999)
+
+ # Read from table several rows
+ # SELECT * FROM my_table WHERE timestamp BETWEEN {} AND {}'.format( int(time.time())-12000, int(time.time()) )
+
+
+ output = 'SELECT * FROM my_table WHERE timestamp BETWEEN {} AND {}'.format(int(time.time())-12000, int(time.time()))
+
+
+ 
+ #########################################
+ # #
+ # The execution exits immediately #
+ # after providing output data #
+ # #
+ #########################################
+
+ recordDone = Record(output, 'Sending value of cnt: {}'.format(output)) 
+ self.return_queue.put(recordDone)

src/Pythonic/element_types.py

@@ -53,6 +53,15 @@ def __getstate__(self):
  #logging.debug('__getstate__() called Record')
  return(self.data, self.message)
 
+
+class PythonicError:
+
+ def __init__(self, msg : str) -> None:
+ self.msg = msg
+ 
+ def __str__(self) -> str:
+ return 'Error: {}'.format(self.msg)
+
 class GuiCMD:
 
  def __init__(self, text):

src/Pythonic/executables/sqlite.py

@@ -1,6 +1,6 @@
-import time, queue, sqlite3
+import time, queue, sqlite3, logging
 try:
- from element_types import Record, Function, ProcCMD, GuiCMD
+ from element_types import Record, Function, ProcCMD, GuiCMD, PythonicError
 except ImportError: 
  from Pythonic.element_types import Record, Function, ProcCMD, GuiCMD
 
@@ -12,7 +12,6 @@ def __init__(self, id, config, inputData, return_queue, cmd_queue):
 
  def execute(self):
 
-
  #####################################
  # #
  # REFERENCE IMPLEMENTATION #
@@ -28,29 +27,36 @@ def execute(self):
  return
 
  filename = None
+ output = None
 
  for attrs in specificConfig:
  if attrs['Name'] == 'Filename':
  filename = attrs['Data']
 
+ if self.inputData is None:
+ recordDone = Record(None, message='No input provided')
+ self.return_queue.put(recordDone)
+ return
+
  con = sqlite3.connect(filename)
- # TODO 
+
  if not con:
  raise Exception('Can not connect to database')
 
- if self.inputData is None:
- output = 0
- else:
- output = self.inputData + 1
+ cur = con.cursor()
 
+ try:
+ cur.execute(self.inputData)
+ except Exception as e:
+ logging.warning(e)
+ recordDone = Record(PythonicError(e), 'Query failed') 
+ self.return_queue.put(recordDone)
+ con.close() 
+ return
 
- 
- #########################################
- # #
- # The execution exits immediately #
- # after providing output data #
- # #
- #########################################
+ output = cur.fetchall()
 
- recordDone = Record(output, 'Sending value of cnt: {}'.format(output)) 
+ con.commit()
+ con.close()
+ recordDone = Record(output, 'Query successful') 
  self.return_queue.put(recordDone)

src/Pythonic/executables/telegram.py

@@ -96,6 +96,7 @@ def message(update, context):
  try:
  dispatcher.bot.send_message(chat_id=chat_id, text=str(cmd.data))
  except Exception as e:
+ # BAUSTELLE # Return Error Element ?
  logging.error(e)
  chat_ids.discard(chat_id)
  logging.warning('ChatId removed')