Psycopg2 callproc和sql参数
Psycopg2是一个用于Python编程语言的PostgreSQL数据库适配器。它提供了与PostgreSQL数据库进行交互的功能，包括执行SQL查询、事务处理、数据导入和导出等。
callproc是Psycopg2库中的一个方法，用于调用存储过程。它接受两个参数：存储过程的名称和参数列表。通过使用callproc方法，可以在Python中调用存储过程并传递参数。
sql参数是一个可选的参数，用于指定要执行的SQL语句。如果提供了sql参数，callproc方法将执行指定的SQL语句，而不是存储过程。
Psycopg2的callproc方法的使用示例：
import psycopg2
# 连接到PostgreSQL数据库
conn = psycopg2.connect(database="mydb", user="myuser", password="mypassword", host="localhost", port="5432")
# 创建游标对象
cur = conn.cursor()
# 调用存储过程
cur.callproc('my_stored_procedure', [param1, param2, param3])
# 获取存储过程的返回结果
result = cur.fetchone()
# 提交事务
conn.commit()
# 关闭游标和数据库连接
cur.close()
conn.close()在上述示例中，我们首先使用psycopg2库连接到PostgreSQL数据库。然后，我们创建一个游标对象，使用callproc方法调用名为'my_stored_procedure'的存储过程，并传递参数param1, param2, param3。最后，我们通过fetchone方法获取存储过程的返回结果，并提交事务。最后，我们关闭游标和数据库连接。
Psycopg2的callproc方法在以下场景中非常有用：
- 调用存储过程并传递参数。
- 执行需要在数据库中执行的复杂操作，而不是在Python代码中执行。
腾讯云提供了云数据库 TencentDB for PostgreSQL，可以与Psycopg2库一起使用。您可以在腾讯云官方网站上找到有关该产品的更多信息和文档。
腾讯云 TencentDB for PostgreSQL产品介绍链接地址：https://cloud.tencent.com/product/postgresql
相关·内容
2回答
我得到了一些SQL函数
CREATE OR REPLACE FUNCTION tools.update_company(IN company_id integer, OUT value integer)
RETURNS integer AS
$BODY$
BEGIN
select * into value from function_making_int(company_id)
END;$BODY$
从Psycopg2 (如果重要的话，它在Django内部)，我做到了
c = connection.cursor()
c.callproc('tools.update_co
浏览 1提问于2010-07-08得票数 6
回答已采纳
1回答
存储过程和预准备语句错误
、、、
我从我的Java应用程序调用一个存储过程，在设置输入参数时得到以下错误。
1:调用过程的Java方法：
public int callProc(String userid, String program_id, String procName)
throws SQLException {
int returnCode = -1;
try {
CallableStatement stmt;
String sql = "CALL " + procName + "(?,?,?,?,?)";
浏览 0提问于2012-09-27得票数 0
回答已采纳
我正在尝试从psycopg2调用一个函数，如下所示：
conn = psycopg2.connect(host="name.host.ex", user="username", password="secret")
cur = conn.cursor()
cur.callproc("f_do_action", ["aaa", "bbb"])
cur.close()
conn.close()
当从psql调用这个函数时，一切正常，但是使用psycopg2似乎什么都没有发生。我也不例外。它只是不调用实际
浏览 0提问于2011-11-13得票数 14
回答已采纳
似乎当我使用callproc()时，psycopg2不能正确地将字符串转换为文本或字符变化。
例如：
values = [pid, 4, 4, 'bureau ama', 0, 130, row['report_dte'], row['report_dte'], 1, 1, 1, None, None, 'published', row['report_dte']]
cur.callproc('header', values)
收益率：
psycopg2.ProgrammingError: func
浏览 5提问于2011-03-11得票数 3
回答已采纳
我在使用callproc()调用带参数的存储过程时遇到错误。
cur.callproc("TEST.manage_partitions_pkg.test", ["to_date('20120525', 'YYYYMMDD')", 1, "tablename_type('MESSAGE', 'VALID_MESSAGE')", True, True])
但是它似乎不能识别SQL参数。我是否需要以某种方式将SQL参数转换为python？如果是这样，将如何做到这一点？
浏览 1提问于2012-06-15得票数 0
回答已采纳
我有这样的代码：
with connections["mssql_database"].cursor() as cursor:
sql = "EXEC SaveActivity @id_workplace=?, @personal_number=?, @id_activity=?"
params = (id_workplace, personal_number, id_activity)
cursor.execute(sql, params)
TypeError:
浏览 8提问于2021-12-21得票数 1
回答已采纳
2回答
我希望通过psycopg2调用plpgsql函数，并查看警告消息。也就是说，我有这个功能：
create or replace function test_warning() returns void as $$
begin
raise warning 'this is only a test';
end;
$$
language plpgsql;
并在python中这样称呼它：
import psycopg2
conn = psycopg2.connect(conn_string)
cursor = conn.cursor()
cursor.callproc("te
浏览 11提问于2014-12-01得票数 24
回答已采纳
我使用pymssql库使用存储过程从MS SQL Server检索数据。在传递强制参数时，我没有问题。
如何在pymssql中传递可选参数？
我存储的proc有5个参数，2个是强制性的，3个是可选的。
procedure_connection.cursor.callproc('PROCEDURE_NAME', (mandatory_parameter_1,mandatory_parameter_2))
我必须按照什么顺序传递可选参数？
procedure_connection.cursor.callproc('PROCEDURE_NAME', (manda
浏览 0提问于2019-04-15得票数 0
回答已采纳
我目前在postgres中有一个自定义类型：
create type times_type as
(
start varchar,
end varchar,
rate real
);
我还有一个函数，它接受一个times_type数组：
create function insert_data(times_values times_type[])
当我使用命名元组并使用callproc一次插入一个值时，它工作得很好，即：
Document = namedtuple('times_type', 'start
浏览 1提问于2018-11-20得票数 2
回答已采纳
我正在尝试使用psycopg2 (从pg_partman run_maintenance_proc())调用一个过程。
我可以从psql命令行执行一个简单的CALL partman.run_maintenance_proc();。但是当我尝试用psycopg2做同样的事情时，我遇到了这个错误：
psycopg2.errors.InvalidTransactionTermination: invalid transaction termination
CONTEXT: PL/pgSQL function partman.run_maintenance_proc(integer,boolean,
浏览 19提问于2021-09-14得票数 0
我对Python还比较陌生。我目前正在Oracle DB中执行SQL语句。
当我执行查询时：
query = 'select * from table'
cursor.execute(query)
result = cursor.fetchall()
一切都很顺利，但是当我尝试执行脚本时：
纯文本脚本：
begin
SIEBEL_DBA.X_DR_DEPLOY(id => '1-4NANEI', env_code => 'SVE_SIT');
end;
/
脚本代码
script = "begin\nSIEBEL_DBA.
浏览 0提问于2014-01-31得票数 6
我正在尝试在Java中调用PL/SQL存储过程。它可以在SQL Developer中工作。当我启动应用程序时，什么也没有发生，也没有收到任何错误消息。数据库中没有任何更改。
代码如下：
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
Connection con=DriverManager.getConnection(
"jdbc:oracle:thin:@localhost:1521:orcl","student
浏览 1提问于2013-06-05得票数 0
1回答
我在Postgres中有一个名为sales的存储过程，它在pgadmin中工作得很好 CALL sales(); 但是，当我从Python调用它时： import psycopg2
conn = psycopg2.connect (host ....)
cur = conn.cursor()
cur.callproc('sales')
conn.commit() 我得到以下错误消息： psycopg2.ProgrammingError: sales() is a procedure
LINE 1: SELECT * FROM sales()
浏览 126提问于2019-03-05得票数 7
由于某种原因，将字符串从Python传递到Postgres函数并使用psycopg2游标调用它会导致函数无法识别，因为参数是未知的。
函数非常简单，如下所示：
CREATE OR REPLACE FUNCTION text_test (some_text text)
RETURNS void AS $$
BEGIN
END;
$$ LANGUAGE plpgsql;
在python方面，我有：
cursor.callproc("text_test", ("test",))
我得到了以下错误：
psycopg2.ProgrammingError: functio
浏览 1提问于2015-02-09得票数 2
回答已采纳
2回答
此代码工作，但不确定如何获得输出？
storedProcedure = "dbo.myproc“游标= conn.cursor() query =”@test_suite_dispatch_id int“；exec {sp} @test_suite_id={id}，@test_suite_dispatch_id = @test_suite_dispatch_id OUTPUT”.format( sp=storedProcedure，ID=TestSuiteData‘’TestSuite_ID‘) print( query ) cursor.execute( query ) curs
浏览 6提问于2015-11-06得票数 2
1回答
我正在使用psycopg2创建一个脚本，该脚本可以执行许多DB函数。到目前为止，我在selects、inserts等方面还没有遇到任何问题，但在调用函数时却遇到了问题。
该函数非常简单：
create or replace function create_sample(_m_id int) returns bigint as
$$
DECLARE
count bigint;
BEGIN
perform update_function(_m_id,true);
select count(*) from table_1 where m_id = _m_id into count;
浏览 0提问于2020-09-30得票数 1
下面是我目前收到的呼叫和错误：
cursor.callproc('DBMS_METADATA.SET_TRANSFORM_PARAM', ['DBMS_METADATA.SESSION_TRANSFORM', 'STORAGE', 'false'])
cx_Oracle.DatabaseError: ORA-06550: line 1, column 7:
PLS-00307: too many declarations of 'SET_TRANSFORM_PARAM' match this call
ORA-06
浏览 3提问于2020-03-04得票数 1
回答已采纳
1回答
我有一张桌子
CREATE TABLE public."Persons"
(
id_persons serial NOT NULL,
name_persons varchar(50) NOT NULL,
telephone_persons varchar(14) NOT NULL,
email_persons varchar(100),
address_persons integer NOT NULL,
photo_persons oid,
login_persons varchar(20) NOT NULL,
p
浏览 14提问于2016-07-25得票数 0
回答已采纳
2回答
我以为例
Oracle
>>> c = db.cursor() # open the database as in the examples above
>>> c.execute("create or replace function funcout (y out varchar2) return varchar2 is begin y := 'tested'; return 'returned'; end;")
>>> params = [None]
>>> c.call
浏览 0提问于2018-12-27得票数 1
回答已采纳
我试图在python类中使用psycopg2调用postgres数据库过程。
lCursor.callproc('dbpackage.proc'，In_parameter1，In_parameter2，out_parameter)。
In_parameter值为5008001#60°V4#FR.tif
但是我得到了下面的错误。DataError:编码"UTF8"：0xb0的无效字节序列
我已经尝试了大部分的解决方案在网上，但没有运气。
浏览 2提问于2016-01-25得票数 0
回答已采纳
我正在尝试使用Python和Cx_Oracle 8.2.1运行一个Oracle存储过程。此过程有两个XMLTYPE参数，一个用于输入，另一个用于输出，它在Oracle中的名称是这样的，工作正常： DECLARE
RXML_OUT XMLTYPE;
BEGIN
RXML_OUT := NULL;
MYPACKAGE.MYPROCEDURE ( IN_SXML, RXML_OUT );
END; 但是，我无法使用Cx_Oracle调用它。我试着这样称呼它： connection = cx_Oracle.connect(config["db"]["us
浏览 67提问于2021-07-26得票数 0
我在PostgreSQL中有一个存储过程，它返回一个反射游标(它的名称可以作为参数传递)：
-- Example stored procedure....
CREATE OR REPLACE FUNCTION example_stored_procedure(ref refcursor, gid_number integer) RETURNS refcursor AS $$
DECLARE
ref refcursor;
BEGIN
OPEN $1 for SELECT * FROM lucca_routes where gid = gid_number;
RETURN $1;
END;
$
浏览 1提问于2018-09-27得票数 2
回答已采纳
如何在python脚本上打印postgres的存储过程？
postgres中的存储过程示例如下：
create or replace function checktime() returns void
language plpgsql
as $$
DECLARE timestart TIMESTAMP;
FOR id from rt LOOP
SELECT timeofday() into timestart;
RAISE NOTICE 'Time now : %', timestart;
END LOOP;
END;
$$
;
在python中，我
浏览 0提问于2018-05-10得票数 5
回答已采纳
1回答
我目前正在使用psycopg2连接到数据库。例如，如果查询失败，我会得到包含整个sql insert语句的错误消息，其中包含敏感信息。有没有办法配置psycopg2，使其不显示sql语句或屏蔽某些字段？ 示例： "ERROR", "message": "(psycopg2.errors.UniqueViolation) duplicate key value violates unique constraint \"pksa_account\"\nDETAIL: Key (b_loadid, customer_account_numb
浏览 93提问于2020-12-02得票数 0
1回答
我在psycopg2中使用psycopg2子句时遇到了困难：
from app.commons.database import conn
from psycopg2 import sql
from psycopg2.extras import DictCursor
query = '''
SELECT
*
FROM
{}.{}
WHERE
{} in %s
'''.format(
sql.Identifier('information_sc
浏览 1提问于2019-11-08得票数 0
回答已采纳
我需要通过callproc调用"sp_executesql“的帮助(我需要它作为RPC)。这是我的代码：
import pymssql
conn = pymssql.connect(host='11.22.33.44:1433', user='sa', password='XYZ', database='AdventureWorks')
cur = conn.cursor()
cur.callproc("sp_executesql", 'SELECT * FROM AdventureWorks.Hu
浏览 1提问于2012-09-06得票数 0
1回答
我使用postgresql函数并从python调用。但我拿不到游标。
这是我的postgresql函数。
CREATE LANGUAGE plpgsql;
create or replace FUNCTION getPerson() returns REFCURSOR
AS $$
DECLARE
p_cursor refcursor;
BEGIN
open p_cursor FOR
select m.name AS name, m.surname AS s
浏览 4提问于2017-09-17得票数 2
回答已采纳
在python中通过psycopg2调用我的postgres存储过程后，我正在尝试获取列名列表...
这是我的代码
# create a connection to the database
conn = psycopg2.connect(...)
# create a cursor object for execution
curs = conn.cursor()
curs.callproc('usp_my_stored_proc', ['mySP'])
# now open a new cursor & "steal" the r
浏览 10提问于2018-02-28得票数 1
回答已采纳
我要在python.The中执行postgres查询，表名必须作为parameter.Since传递，该表将在运行时创建。我已经使用了dict查询参数style.But，我得到一个错误。
import psycopg2
CONNECTION_STRING = "dbname='autogist' user='postgres' password=''"
query = "INSERT INTO %(table)s " +\
"(vin_id, vin_details_id,
浏览 0提问于2012-10-11得票数 2
回答已采纳
2回答
我想用Python执行一个Oracle过程。SQL端的过程写得很好。在Python代码中，它收到错误: ORA-06550和PLS-00306 - DatabaseError。
con = cx_Oracle.connect('***********')
cur = con.cursor()
faktura= "QQ0009365/21"
numer_listu = "421435636356536"
kod_k = int(112377)
out_data=str()
t = cur.callproc('QQ.ECOMMERCE.ZMI
浏览 5提问于2021-09-03得票数 0
存储过程:
CREATE OR REPLACE FUNCTION try_create() RETURNS INT AS $$
BEGIN
CREATE TABLE hello(id SERIAL PRIMARY KEY, name TEXT);
RETURN 1;
END ;
$$ LANGUAGE plpgsql;
test.py
import psycopg2
conn = psycopg2.connect(user='a', password='a', dbname='a')
cur = conn.c
浏览 5提问于2018-01-05得票数 1
回答已采纳
1回答
我想知道如何在Psycopg2中将Postgres函数传递给insert语句中的字段。我在文件里找遍了也找不到答案。
代码：
在DBconn类中：
def insert(self, table, data):
fields = data.keys()
sql = "INSERT INTO " + table + "("
sql += ",".join(fields) + ") VALUES (" + ",".join(["%s"]*len(fields)) + ")
浏览 0提问于2014-05-07得票数 0
2回答
我刚刚意识到psycopg2允许在一个execute调用中进行多个查询。
例如，这段代码实际上将在my_table中插入两行
>>> import psycopg2
>>> connection = psycopg2.connection(database='testing')
>>> cursor = connection.cursor()
>>> sql = ('INSERT INTO my_table VALUES (1, 2);'
... 'INSERT INT
浏览 3提问于2013-09-06得票数 1
在Postgres数据库上，我使用的是烧瓶并制作程序，如
CREATE OR REPLACE FUNCTION "public"." "()
RETURNS "pg_catalog"."refcursor" AS $BODY$
DECLARE
ref refcursor;
BEGIN
OPEN ref FOR select posts.*, users.username, users.name from posts left join users on posts.user_id = users.id;
浏览 0提问于2018-03-04得票数 3
回答已采纳
1回答
如何在jdbc中检索%类型记录的表。当我运行java代码时，我得到ORA-04043:对象"PERSON_TB“不存在。 编译成功的包： CREATE OR REPLACE PACKAGE MYPKG AS
TYPE personrec IS RECORD(
id VARCHAR2(10));
type_person_rec personrec;
TYPE person_tb IS TABLE OF type_person_rec%TYPE;
PROCEDURE callproc(persondata OUT person_tb);
END MYPKG;
/
浏览 11提问于2019-10-14得票数 1
1回答
我用的是酒瓶，psycopg2和uWSGI。我将psycopg2.ThreadConnectionPool用于DB连接池，只有cursor.callproc用于查询DB。
问题:有时，在并发请求期间，过程调用结果被混合在一起，代码正在查询procedure_1，但正在为procedure_2获取结果(反之亦然)。即使在uwsgi.ini中有threads=1，并且只有processes用于并发。maxconn for psycopg2.ThreadConnectionPool设置为1。如果processes设置为1 (在uwsgi.ini中)，问题就会消失。
是什么导致了这个问题？
下面是再现
浏览 1提问于2014-12-08得票数 5
回答已采纳
我有一个使用psql命令行加载的.sql文件。这个文件包含我所有的函数定义。我从python脚本调用该文件中定义的函数。
我正面临着一个奇怪的问题。我在.sql文件中声明了一个函数，如下所示：
CREATE OR REPLACE FUNCTION Add_to_stroke(my_stroke VARCHAR(50))
RETURNS VOID
AS $$
BEGIN
INSERT INTO stroke VALUES (my_stroke);
END $$
LANGUAGE plpgsql
VOLATILE;
我从python文件中调用这个函数，如下所示：
c
浏览 1提问于2017-04-12得票数 2
回答已采纳
I have sql procedure and I have some python variables I want to run this procedure along with using this variables as dynamic
` I have sql procedure and I have some python variables I want to run this procedure along with using this variables as dynamic `
CREATRE OR REPLACE PROCEDUE SQURT_EN_UR(
浏览 9提问于2022-10-26得票数 0
回答已采纳
1回答
寻找一些帮助，我有一个问题，psycopg2和Python3。我正在尝试使用2.7.1版本中可用的来自psycopg2的sql库。当尝试使用
from psycopg2 import sql
我得到错误消息未解析引用'sql‘
我使用XubuntuLinux16.04LTS并在发出命令时
pip show psycopg2
在终点站我得到：
Name: psycopg2
Version: 2.7.1
Summary: psycopg2 - Python-PostgreSQL Database Adapter
Home-page: http://initd.org/psycopg/
浏览 3提问于2017-03-26得票数 1
我使用execute_values插入数据，这需要一个sql查询。按照文档中的建议，使用psycopg2.sql.SQL构造查询，但execute_values不接受该对象。
下面是我的代码：
import psycopg2 as pg
from psycopg2 import extras
from psycopg2 import sql
config = {
'host' : 'localhost',
'user' : 'username',
'password' : 'pas
浏览 16提问于2018-09-15得票数 9
回答已采纳
我有一个由psycopg2提供的简单的数据库查询，但是我不知道为什么它总是显示错误--这里是代码
ip ="127.0.0.1"
sql="select count(*) from radacct where nasipaddress=%s"
cur.execute(sql,ip)
然后它会显示
TypeError:不是所有在字符串格式化期间转换的参数
如果我试着这样做
cur.execute("select count(*) from radacct where nasipaddress=%s" % ip)
它还是不起作用
如何将参数传递给
浏览 5提问于2014-06-18得票数 3
回答已采纳
1回答
我在PostgreSQL中有一个存储过程，它采用如下定义的t_document复合类型：
CREATE TYPE t_document AS (
title text,
metadata text,
data text
);
该存储过程还接受其他参数，签名如下：
CREATE or REPLACE FUNCTION sp_insertItem
(
name varchar(100) ,
phone varchar(100) ,
address varchar(150) ,
document t_document
)
从
浏览 0提问于2011-11-21得票数 1
回答已采纳
3回答
我在一个循环中多次从Python执行一个自写的postgresql函数。我正在使用psycopg2框架来做这件事。我编写的函数具有以下结构：
CREATE OR REPLACE FUNCTION my_func()
RETURNS void AS
$$
BEGIN
-- create a temporary table that should be deleted after
-- the functions finishes
-- normally a CREATE TABLE ... would be here
CREATE TEMPORARY TABL
浏览 7提问于2017-01-26得票数 1
回答已采纳
2回答
pyscopg2选择空值
、、、
如何在中使用Psycopg2来处理空值和非空值？
例如：
sql = 'SELECT * FROM table WHERE col = %s;'
possible_params = [1, None]
for x in possible_params:
print cur.mogrify(sql,(x,))
我需要第一个查询看起来像SELECT * FROM table WHERE col = 1;，第二个查询是SELECT * FROM table WHERE col IS NULL;的功能等效。
有什么诡计吗？我有许多列可能为NULL或具有一个值，因此动态构建SQ
浏览 2提问于2014-02-10得票数 8
回答已采纳
1回答
connection = engine.raw_connection()
cursor = connection.cursor()
cursor.callproc('transfer', [1, 2, 1000])# fetch result parameters
results = list(cursor.fetchall())
cursor.close()
connection.commit()
connection.close()
我得到了这个错误：
回溯(最近一次调用)：文件"D:\z_data\PYTHON\oops\sql_statements.py"
浏览 3提问于2021-05-25得票数 0
正如Django文档中所提到的，我们可以通过使用诸如cursor.callproc('find_all')之类的游标对象来执行存储过程。
我还知道我们还可以通过这个方法model.object.raw("call SPName")调用Django中的存储过程。
我想知道这两种方法中哪一种在性能、可读性、防止sql注入等攻击方面更好，以及对给定解决方案的解释。
浏览 1提问于2018-09-07得票数 1
cur.execute('UPDATE newslib SET (keyword1) = %s WHERE id= %s' % m_k1,row[0])
我使用psycopg2来执行这个SQL语句。m_k1和row[0]是我想传递给语句的两个变量。
这将触发以下错误消息：
TypeError: not enough arguments for format string
我一直在网上寻找解决方案，但我无法解决。
浏览 3提问于2014-02-08得票数 1
回答已采纳
我试图使用Python和psycopg2驱动程序构建一个涉及Postgres中json列的动态查询。
where_clause = ''
parameters = []
for key, v in (arguments):
parameters.append(key)
parameters.append(v)
where_clause = where_clause + "data @> '{\"%s\":%s}' AND "
sql = u'select * from my_table w
浏览 0提问于2017-01-03得票数 1
1回答
在psycopg2文档中，它引用了一个充满乐趣的属性，以安全地构造strings。然而，我在python 3上的安装(应该是来自PyPI的最新版本)不包含这样的属性：
from psycopg2 import sql
# ImportError: cannot import name 'sql'
import psycopg2
print(dir(psycopg2)) # no mention of sql, although dir is not complete
# in the REPL
help(psycopg2) # no mention of the sql s
浏览 1提问于2017-01-26得票数 1
回答已采纳
1回答
当试图将日期时间插入mysql数据库时，我会得到这个语法错误。
pymysql.err.ProgrammingError: (1064, "You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near '00:00:01)' at line 1")
我正在使用pymysql和烧瓶-mysql。这是我的密码：
cursor.execute(""
浏览 2提问于2022-01-23得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
