无法通过 pyodbc 从 PostgreSQL 数据库上的一个表中进行选择 - 如何调试

Question

我有一个postgresql数据库，其中包含一些由drupal制作的表，以及其他我自己制作的表。然后我有一个python api，使用pyodbc来查询数据库。

只有一张桌子，我无法通过pyodbc进行选择。如果我打印查询并将其粘贴到pgadminIII中，那么它会给出预期的结果，如果我更改python代码中的表，它会给出正确的结果。

查询是

select id from a_company where name = 'somename'

结果

7
8
9

etc（50行int id）

我的python代码是

sql = """select id from a_company where name = 'somename'"""
curs = self._connection.cursor()
sql = self._ConvertToPostGres(sql) #drops [] etc, as the initial code was for MSSQL
curs.execute(sql)
f = curs.fetchall()

通过pyodbc的呼叫返回

None

（我可以使用相同的连接从其他表中进行选择，所以连接字符串无关紧要？）

我的最佳猜测是，这是一个权限问题，我对这个特定的表做了一些愚蠢的事情。

有人能建议如何调试吗？

通过pgadmin:创建表格

-- Table: a_company
-- DROP TABLE a_company;
CREATE TABLE a_company
(
  id integer NOT NULL DEFAULT nextval('a_company_id_seq'::regclass),
  name character varying,
  abn character varying,
  url character varying,
  anzsic character varying(5),
  address character varying,
  area integer,
  sell_equipment boolean,
  recycling_provider boolean,
  monthly_matches boolean,
  user_id bigint,
  latitude double precision,
  longitude double precision,
  geography geography,
  CONSTRAINT a_company_pkey PRIMARY KEY (id),
  CONSTRAINT fk_a_company_a_anzsic_codes FOREIGN KEY (anzsic)
      REFERENCES a_anzsic_codes (code) MATCH SIMPLE
      ON UPDATE NO ACTION ON DELETE NO ACTION
)
WITH (
  OIDS=FALSE
);
ALTER TABLE a_company
  OWNER TO aspire;
-- Index: fki_a_company_aspire_a_codes
-- DROP INDEX fki_a_company_aspire_a_codes;
CREATE INDEX fki_a_company_aspire_a_codes
  ON a_company
  USING btree
  (anzsic COLLATE pg_catalog."default");

如果我修改到只更改表名，那么我会得到另一个"正常工作"的表。但我将id行更改为id串行，而不是指定序列。

Answer 1

您可以尝试以下操作：

def load_data(sql, columns):
    sql_data = []
    curs = self._connection.cursor()
    sql = self._ConvertToPostGres(sql)
    try:
        curs.execute(sql)
        rows = curs.fetchall()
        pass
    except Exception as e:
        print(e)
        rows = pd.read_sql(sql, self._connection)
    for row in rows:
        sql_data.append(list(row))
    df = pd.DataFrame(data=sql_data, columns=columns)
    return df

sql = "select id from a_company where name = '{0}'".format(somename)
data = load_data(sql, ['id'])