execCurrent.c Source File (original) (raw)

43bool

48{

49 char *cursor_name;

50 char *table_name;

57 else

62 if (table_name == NULL)

70 errmsg("cursor \"%s\" does not exist", cursor_name)));

79 errmsg("cursor \"%s\" is not a SELECT query",

80 cursor_name)));

85 errmsg("cursor \"%s\" is held from a previous transaction",

86 cursor_name)));

96 {

100

101

102

103

106 {

108

111 continue;

112

114 {

118 errmsg("cursor \"%s\" has multiple FOR UPDATE/SHARE references to table \"%s\"",

119 cursor_name, table_name)));

121 }

122 }

123

127 errmsg("cursor \"%s\" does not have a FOR UPDATE/SHARE reference to table \"%s\"",

128 cursor_name, table_name)));

129

130

131

132

133

137 errmsg("cursor \"%s\" is not positioned on a row",

138 cursor_name)));

139

140

142 {

144 return true;

145 }

146

147

148

149

150

151

152 return false;

153 }

154 else

155 {

156

157

158

159

160

163

169 errmsg("cursor \"%s\" is not a simply updatable scan of table \"%s\"",

170 cursor_name, table_name)));

171

172

173

174

175

176

177

178

182 errmsg("cursor \"%s\" is not positioned on a row",

183 cursor_name)));

184

185

186

187

188

189

191 return false;

192

193

194

195

196

197

199 {

200

201

202

203

204

206

208 }

209 else

210 {

211

212

213

214

215

216

218 bool lisnull;

220

221#ifdef USE_ASSERT_CHECKING

224 &lisnull);

225 if (lisnull)

228 errmsg("cursor \"%s\" is not a simply updatable scan of table \"%s\"",

229 cursor_name, table_name)));

231#endif

232

235 &lisnull);

236 if (lisnull)

239 errmsg("cursor \"%s\" is not a simply updatable scan of table \"%s\"",

240 cursor_name, table_name)));

242

244 }

245

247

248 return true;

249 }

250}

251

252

253

254

255

256

257static char *

259{

261

264 {

267

268

271 else

273

275 {

276

280 errmsg("type of parameter %d (%s) does not match that when preparing the plan (%s)",

281 paramId,

284

285

287 }

288 }

289

292 errmsg("no value found for parameter %d", paramId)));

294}

295

296

297

298

299

300

301

302

303

304

305

306

307

308

309

310

311

312

316{

318

319 if (node == NULL)

322 {

323

324

325

326

327

328

329

330

331

332

342 {

344

347 result = sstate;

348 break;

349 }

350

351

352

353

354

355

356

357

358

359

360

361

362

363

364

365

366

367

368

369

370

371

372

374 {

376 int i;

377

379 {

383

384 if (!elem)

385 continue;

386 if (result)

387 return NULL;

388 result = elem;

389 }

390 break;

391 }

392

393

394

395

396

402 break;

403

404

405

406

411 break;

412

413 default:

414

415 break;

416 }

417

418

419

420

421

424

425 return result;

426}

#define TextDatumGetCString(d)

#define Assert(condition)

#define OidIsValid(objectId)

int errcode(int sqlerrcode)

#define ereport(elevel,...)

static ScanState * search_plan_tree(PlanState *node, Oid table_oid, bool *pending_rescan)

static char * fetch_cursor_param_value(ExprContext *econtext, int paramId)

bool execCurrentOf(CurrentOfExpr *cexpr, ExprContext *econtext, Oid table_oid, ItemPointer current_tid)

#define outerPlanState(node)

char * format_type_be(Oid type_oid)

ItemPointerData * ItemPointer

static bool ItemPointerIsValid(const ItemPointerData *pointer)

char * get_rel_name(Oid relid)

#define IsA(nodeptr, _type_)

#define RowMarkRequiresRowShareLock(marktype)

Portal GetPortalByName(const char *name)

static Oid DatumGetObjectId(Datum X)

static Pointer DatumGetPointer(Datum X)

#define RelationGetRelid(relation)

ExecRowMark ** es_rowmarks

Index es_range_table_size

ParamListInfo ecxt_param_list_info

ItemPointerData xs_heaptid

Relation ss_currentRelation

#define TableOidAttributeNumber

#define SelfItemPointerAttributeNumber

static Datum slot_getsysattr(TupleTableSlot *slot, int attnum, bool *isnull)