code: def test_sql_query(self):
      t_env = self.t_env
      source = t_env.from_elements(
          [(1, "Hi", "Hello"), (2, "Hello", "Hello")], ["a", "b", "c"]
      )
      sink_table_ddl = """
          CREATE TABLE sinks_sql_query(a BIGINT, b STRING, c STRING) WITH ('connector'='test-sink')
          """
      t_env.execute_sql(sink_table_ddl)
  
      result = t_env.sql_query("select a + 1, b, c from %s" % source)
      result.execute_insert("sinks_sql_query").wait()
      actual = source_sink_utils.results()
  
      expected = ["+I[2, Hi, Hello]", "+I[3, Hello, Hello]"]
      self.assert_equals(actual, expected)
  
file_path: flink/flink-python/pyflink/table/tests/test_sql.py
imports: import glob
  import os
  import subprocess
  from pyflink.find_flink_home import _find_flink_source_root
  from pyflink.java_gateway import get_gateway
  from pyflink.table import ResultKind, ExplainDetail
  from pyflink.table import expressions
  from pyflink.testing import source_sink_utils
  from pyflink.testing.test_case_utils import PyFlinkStreamTableTestCase, PyFlinkTestCase
label_desc: Use image node_id 2 for calling the StreamSqlTests obj's underlying member method code with example usage: obj.test_sql_query() without return types