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

Lines Matching defs:query
127 	char *query;
156 	char *query;
304 		/* running a sync query, stop it */
784 		    result->is_prepared ? "prepared " : "", result->query);
823 		/* Multi-page query finishes now. Log a debug/warning summary
837 	i_free(result->query);
929 		/* Timeouts bring uncertainty whether the query succeeded or
931 		   enough copies of the data for the query to succeed. */
938 			result->query, (int)errsize, errmsg, msecs/1000, msecs%1000,
968 		/* non-fallback query finished successfully. if there had been
1024 	/* If last primary query sent timestamp + msecs is older than current
1025 	   time, we need to retry the primary query. Note that this practically
1031 	   parallel is when the earlier query is being slow and hasn't finished
1033 	   first query might have to wait for a timeout, Cassandra could have
1034 	   been fixed in the meantime and the second query finishes
1110 driver_cassandra_query_init(struct cassandra_db *db, const char *query,
1124 	result->query = i_strdup(query);
1131 driver_cassandra_query_full(struct sql_db *_db, const char *query,
1138 	result = driver_cassandra_query_init(db, query, query_type, FALSE,
1140 	result->statement = cass_statement_new(query, 0);
1144 static void driver_cassandra_exec(struct sql_db *db, const char *query)
1146 	driver_cassandra_query_full(db, query, CASSANDRA_QUERY_TYPE_WRITE, exec_callback, NULL);
1149 static void driver_cassandra_query(struct sql_db *db, const char *query,
1152 	driver_cassandra_query_full(db, query, CASSANDRA_QUERY_TYPE_READ, callback, context);
1190 driver_cassandra_sync_query(struct cassandra_db *db, const char *query,
1208 	driver_cassandra_query_full(&db->api, query, query_type,
1228 driver_cassandra_query_s(struct sql_db *_db, const char *query)
1234 	result = driver_cassandra_sync_query(db, query,
1315 	result->error = i_strdup("Paged query has more results, but not supported by the caller");
1363 	new_result = driver_cassandra_query_init(db, old_result->query,
1496 	i_free(ctx->query);
1543 	if (ctx->failed || (ctx->query == NULL && ctx->stmt == NULL)) {
1552 	/* just a single query, send it */
1553 	const char *query = ctx->query != NULL ?
1554 		ctx->query : sql_statement_get_query(&ctx->stmt->stmt);
1555 	if (strncasecmp(query, "DELETE ", 7) == 0)
1560 	if (ctx->query != NULL) {
1563 		cass_result = driver_cassandra_query_init(db, query, query_type,
1565 		cass_result->statement = cass_statement_new(query, 0);
1574 			driver_cassandra_query_init(db, query, query_type, TRUE,
1595 	/* just a single query, send it */
1596 	if (strncasecmp(ctx->query, "DELETE ", 7) == 0)
1601 	result = driver_cassandra_sync_query(db, ctx->query, query_type);
1621 	if (ctx->query != NULL && !ctx->failed)
1642 driver_cassandra_update(struct sql_transaction_context *_ctx, const char *query,
1650 	if (ctx->query != NULL || ctx->stmt != NULL) {
1654 	ctx->query = i_strdup(query);
1983 	const char *query = sql_statement_get_query(_stmt);
1986 	stmt->result = driver_cassandra_query_init(db, query,
1997 		stmt->result->statement = cass_statement_new(query, 0);
2026 	if (ctx->query != NULL || ctx->stmt != NULL) {
2033 		ctx->query = i_strdup(sql_statement_get_query(_stmt));
2050 		.query = driver_cassandra_query,