HYTOS

    @staticmethod

    def save_stream_line_data(stream_line_list: list):

        import uuid

        app_doc_data = AppDocData.instance()

        with app_doc_data.project.database.connect() as conn:

            try:

                cursor = conn.cursor()

                for stream_line in stream_line_list:

                    sql = f"insert into Streamlines(HMB_UID,[From],[To]) values" \

                          f"((select UID from HMB where StreamNumber=?),?,?)"

                    params = (stream_line[0], stream_line[1], stream_line[2])

                    affected = cursor.execute(sql, params)

            except Exception as ex:

                # Roll back any change if something goes wrong

                conn.rollback()

                from App import App

                message = f"error occurred({repr(ex)}) in {sys.exc_info()[-1].tb_frame.f_code.co_filename}:" \

                          f"{sys.exc_info()[-1].tb_lineno}"

                App.mainWnd().addMessage.emit(MessageType.Error, message)

    def get_stream_lines(self, hmb_uid: str) -> list:

        """get stream lines related to hmb"""

        with self.project.database.connect() as conn:

            try:

                # Get a cursor object

                cursor = conn.cursor()

                sql = f"select * from Streamlines where HMB_UID = ?"

                sql = self.project.database.to_sql(sql)

                params = (hmb_uid,)

                cursor.execute(sql, params)

                return cursor.fetchall()

            # Catch the exception

            except Exception as ex:

                # Roll back any change if something goes wrong

                conn.rollback()

                from App import App

                message = f"error occurred({repr(ex)}) in {sys.exc_info()[-1].tb_frame.f_code.co_filename}:" \

                          f"{sys.exc_info()[-1].tb_lineno}"

                App.mainWnd().addMessage.emit(MessageType.Error, message)