row0sel.ic
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:2k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /******************************************************
  2. Select
  3. (c) 1997 Innobase Oy
  4. Created 12/19/1997 Heikki Tuuri
  5. *******************************************************/
  6. #include "que0que.h"
  7. /*************************************************************************
  8. Gets the plan node for the nth table in a join. */
  9. UNIV_INLINE
  10. plan_t*
  11. sel_node_get_nth_plan(
  12. /*==================*/
  13. /* out: plan node */
  14. sel_node_t* node, /* in: select node */
  15. ulint i) /* in: get ith plan node */
  16. {
  17. ut_ad(i < node->n_tables);
  18. return(node->plans + i);
  19. }
  20. /*************************************************************************
  21. Resets the cursor defined by sel_node to the SEL_NODE_OPEN state, which means
  22. that it will start fetching from the start of the result set again, regardless
  23. of where it was before, and it will set intention locks on the tables. */
  24. UNIV_INLINE
  25. void
  26. sel_node_reset_cursor(
  27. /*==================*/
  28. sel_node_t* node) /* in: select node */
  29. {
  30. node->state = SEL_NODE_OPEN;
  31. }
  32. /**************************************************************************
  33. Performs an execution step of an open or close cursor statement node. */
  34. UNIV_INLINE
  35. que_thr_t*
  36. open_step(
  37. /*======*/
  38. /* out: query thread to run next or NULL */
  39. que_thr_t* thr) /* in: query thread */
  40. {
  41. sel_node_t* sel_node;
  42. open_node_t* node;
  43. ulint err;
  44. ut_ad(thr);
  45. node = thr->run_node;
  46. ut_ad(que_node_get_type(node) == QUE_NODE_OPEN);
  47. sel_node = node->cursor_def;
  48. err = DB_SUCCESS;
  49. if (node->op_type == ROW_SEL_OPEN_CURSOR) {
  50. /* if (sel_node->state == SEL_NODE_CLOSED) { */
  51. sel_node_reset_cursor(sel_node);
  52. /* } else {
  53. err = DB_ERROR;
  54. } */
  55. } else {
  56. if (sel_node->state != SEL_NODE_CLOSED) {
  57. sel_node->state = SEL_NODE_CLOSED;
  58. } else {
  59. err = DB_ERROR;
  60. }
  61. }
  62. if (err != DB_SUCCESS) {
  63. /* SQL error detected */
  64. fprintf(stderr, "SQL error %lun", (ulong) err);
  65. ut_error;
  66. }
  67. thr->run_node = que_node_get_parent(node);
  68. return(thr);
  69. }