def METHOD_NAME(self):
    assert self.adapter.engine.url.database
    sql_command = f".import '|cat -' \"{self.table_name}\""
    command = ["sqlite3", "-csv", self.adapter.engine.url.database, sql_command]
    process = subprocess.Popen(command, stdin=PIPE, stdout=PIPE)
    for line_number, line in enumerate(self.resource.byte_stream, start=1):
        if line_number > 1:
            process.stdin.write(line)  # type: ignore
        self.report_progress(f"{self.resource.stats.bytes} bytes")
    process.stdin.close()  # type: ignore
    process.wait()