一.处理:
# -*- coding: utf-8-*- import psycopg2 ## 连接到一个给定的数据库 conn = psycopg2.connect(database="******", user="******",password="******", host="127.0.0.1", port="5432") ## 建立游标，用来执行数据库操作 cursor = conn.cursor() print("====cursor====") print(cursor) ## 执行SQL SELECT命令 # cursor.execute("select * from accounts") # cursor.execute("select * from developer_key_account_bindings") #cursor.execute("select count(*) from users") sql = "select order_contexts.context_id, count(order_contexts.context_id) from mooc_orders inner join order_contexts on mooc_orders.id=order_contexts.mooc_order_id where mooc_orders.college_id=1 and order_contexts.context_type='book' GROUP BY order_contexts.context_id ORDER BY count(order_contexts.context_id) DESC LIMIT 10;" cursor.execute(sql) # t = cursor.execute("insert into developer_key_account_bindings(id,account_id,developer_key_id,workflow_state) values(1, 1, 2, 'on')") # print("===t=====") # print(t) ## 获取SELECT返回的元组 rows = cursor.fetchall() print("=========rows=============") print(rows) #for row in rows: # print('id = ',row[0], '2 = ', row[1],'3 = ', row[2], ' ') # 关闭游标 cursor.close() # 关闭数据库连接 conn.close()