def _create_table()

in datastore/providers/analyticdb_datastore.py [0:0]


    def _create_table(self, cur: psycopg2.extensions.cursor):
        cur.execute(
            f"""
              CREATE TABLE IF NOT EXISTS {self.collection_name} (
                id TEXT PRIMARY KEY DEFAULT uuid_generate_v4()::TEXT,
                source TEXT,
                source_id TEXT,
                content TEXT,
                document_id TEXT,
                author TEXT,
                url TEXT,
                created_at TIMESTAMPTZ DEFAULT NOW(),
                embedding real[]
            );
            """
        )