Method query

integration-tests/tests/pg/pg-proxy.test.ts:29–56

(sql: string, params: any[], method: 'all' | 'execute')

	}

	async query(sql: string, params: any[], method: 'all' | 'execute') {
		if (method === 'all') {
			try {
				const result = await this.db.query({
					text: sql,
					values: params,
					rowMode: 'array',
				});

				return { data: result.rows as any };
			} catch (e: any) {
				return { error: e };
			}
		} else if (method === 'execute') {
			try {
				const result = await this.db.query({
					text: sql,
					values: params,
				});

				return { data: result.rows as any };
			} catch (e: any) {
				return { error: e };
			}
		} else {
			return { error: 'Unknown method value' };
		}
	}

	async migrations(queries: string[]) {
		await this.db.query('BEGIN');