gprs_database.py 文件源码

def delete_records(self, timestamp):
        """Deletes records older than the given epoch timestamp."""
        timestamp = psycopg2.TimestampFromTicks(timestamp)
        template = 'delete from %s where record_timestamp < %s'
        command = template % (self.table_name, timestamp)
        with self.connection.cursor() as cursor:
            cursor.execute(command)
            self.connection.commit()