Cross Reference: /dovecot/src/lib-sql/driver-pgsql.c

Lines Matching defs:query
83 			    struct sql_transaction_query *query);
140 		/* running a sync query, stop it */
474 static void do_query(struct pgsql_result *result, const char *query)
488 	if (PQsendQuery(db->pg, query) == 0 ||
490 		/* failed to send query */
540 static void driver_pgsql_exec(struct sql_db *db, const char *query)
549 	do_query(result, query);
552 static void driver_pgsql_query(struct sql_db *db, const char *query,
563 	do_query(result, query);
607 driver_pgsql_sync_query(struct pgsql_db *db, const char *query)
624 	driver_pgsql_query(&db->api, query, pgsql_query_s_callback, db);
645 driver_pgsql_query_s(struct sql_db *_db, const char *query)
651 	result = driver_pgsql_sync_query(db, query);
900 		struct sql_transaction_query *query = ctx->ctx.head;
903 		sql_query(ctx->ctx.db, query->query,
904 			  transaction_update_callback, query);
945 			    struct sql_transaction_query *query)
948 		(struct pgsql_transaction_context *)query->trans;
957 	if (query->affected_rows != NULL) {
961 				query->affected_rows) < 0)
971 				 struct sql_transaction_query *query)
974 		(struct pgsql_transaction_context *)query->trans;
983 	if (query->affected_rows != NULL) {
987 				query->affected_rows) < 0)
1013 		/* just a single query, send it */
1014 		sql_query(_ctx->db, _ctx->head->query,
1018 		i_assert(_ctx->db->v.query == driver_pgsql_query);
1025 		  struct sql_result *result, const char *query)
1028 	ctx->error = t_strdup_printf("%s (query: %s)",
1029 				     sql_result_get_error(result), query);
1038 	struct sql_transaction_query *query;
1048 	for (query = ctx->ctx.head; query != NULL; query = query->next) {
1049 		result = driver_pgsql_sync_query(db, query->query);
1051 			commit_multi_fail(ctx, result, query->query);
1054 		if (query->affected_rows != NULL) {
1059 					query->affected_rows) < 0)
1079 		/* just a single query, send it */
1081 		result = sql_query_s(_ctx->db, single_query->query);
1147 driver_pgsql_update(struct sql_transaction_context *_ctx, const char *query,
1153 	sql_transaction_add_query(_ctx, ctx->query_pool, query, affected_rows);
1179 		.query = driver_pgsql_query,