def _initialize_db()

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


    def _initialize_db(self):
        conn = self.connection_pool.getconn()
        try:
            with conn.cursor() as cur:
                self._create_table(cur)
                self._create_embedding_index(cur)
                conn.commit()
        finally:
            self.connection_pool.putconn(conn)