开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
Exec_query_sys.cpp
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：18k
源码类别：

MySQL数据库

开发平台：

Visual C++

Exec_query_sys.cpp：源码内容
  1. /* Copyright (C) 2003 MySQL AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  17. #include <NdbApi.hpp>
  18. #include <common/ResultArea.hpp>
  19. #include <codegen/Code_query_sys.hpp>
  20. #include <codegen/Code_table.hpp>
  22. #define NULL_CHAR ((char*)0)
  23. #define NULL_INT (-2147483647)
  25. struct Typeinfo {
  26.     const char* m_type_name; // 1
  27.     int m_data_type; // 2
  28.     int m_column_size; // 3
  29.     const char* m_literal_prefix; // 4
  30.     const char* m_literal_suffix; // 5
  31.     const char* m_create_params; // 6
  32.     int m_nullable; // 7
  33.     int m_case_sensitive; // 8
  34.     int m_searchable; // 9
  35.     int m_unsigned_attribute; // 10
  36.     int m_fixed_prec_scale; // 11
  37.     int m_auto_unique_value; // 12
  38.     const char* m_local_type_name; // 13
  39.     int m_minimum_scale; // 14
  40.     int m_maximum_scale; // 15
  41.     int m_sql_data_type; // 16
  42.     int m_sql_datetime_sub; // 17
  43.     int m_num_prec_radix; // 18
  44.     int m_interval_precision; // 19
  45. };
  47. static const Typeinfo
  48. typeinfoList[] = {
  49.     { "CHAR", // 1
  50. SQL_CHAR, // 2
  51. 8000, // 3
  52. "'", // 4
  53. "'", // 5
  54. "length", // 6
  55. SQL_NULLABLE, // 7
  56. SQL_TRUE, // 8
  57. SQL_SEARCHABLE, // 9
  58. NULL_INT, // 10
  59. SQL_FALSE, // 11
  60. NULL_INT, // 12
  61. NULL_CHAR, // 13
  62. NULL_INT, // 14
  63. NULL_INT, // 15
  64. SQL_CHAR, // 16
  65. NULL_INT, // 17
  66. NULL_INT, // 18
  67. NULL_INT // 19
  68.     },
  69.     { "VARCHAR", // 1
  70. SQL_VARCHAR, // 2
  71. 8000, // 3
  72. "'", // 4
  73. "'", // 5
  74. "length", // 6
  75. SQL_NULLABLE, // 7
  76. SQL_TRUE, // 8
  77. SQL_SEARCHABLE, // 9
  78. NULL_INT, // 10
  79. SQL_FALSE, // 11
  80. NULL_INT, // 12
  81. NULL_CHAR, // 13
  82. NULL_INT, // 14
  83. NULL_INT, // 15
  84. SQL_VARCHAR, // 16
  85. NULL_INT, // 17
  86. NULL_INT, // 18
  87. NULL_INT // 19
  88.     },
  89.     { "BINARY", // 1
  90. SQL_BINARY, // 2
  91. 8000, // 3
  92. "'", // 4
  93. "'", // 5
  94. "length", // 6
  95. SQL_NULLABLE, // 7
  96. SQL_TRUE, // 8
  97. SQL_SEARCHABLE, // 9
  98. NULL_INT, // 10
  99. SQL_FALSE, // 11
  100. NULL_INT, // 12
  101. NULL_CHAR, // 13
  102. NULL_INT, // 14
  103. NULL_INT, // 15
  104. SQL_BINARY, // 16
  105. NULL_INT, // 17
  106. NULL_INT, // 18
  107. NULL_INT // 19
  108.     },
  109.     { "VARBINARY", // 1
  110. SQL_VARBINARY, // 2
  111. 8000, // 3
  112. "'", // 4
  113. "'", // 5
  114. "length", // 6
  115. SQL_NULLABLE, // 7
  116. SQL_TRUE, // 8
  117. SQL_SEARCHABLE, // 9
  118. NULL_INT, // 10
  119. SQL_FALSE, // 11
  120. NULL_INT, // 12
  121. NULL_CHAR, // 13
  122. NULL_INT, // 14
  123. NULL_INT, // 15
  124. SQL_VARBINARY, // 16
  125. NULL_INT, // 17
  126. NULL_INT, // 18
  127. NULL_INT // 19
  128.     },
  129.     { "SMALLINT", // 1
  130. SQL_SMALLINT, // 2
  131. 4, // 3
  132. NULL_CHAR, // 4
  133. NULL_CHAR, // 5
  134. NULL_CHAR, // 6
  135. SQL_NULLABLE, // 7
  136. SQL_FALSE, // 8
  137. SQL_SEARCHABLE, // 9
  138. SQL_FALSE, // 10
  139. SQL_TRUE, // 11
  140. SQL_FALSE, // 12
  141. NULL_CHAR, // 13
  142. NULL_INT, // 14
  143. NULL_INT, // 15
  144. SQL_SMALLINT, // 16
  145. NULL_INT, // 17
  146. 10, // 18
  147. NULL_INT // 19
  148.     },
  149.     { "SMALLINT UNSIGNED", // 1
  150. SQL_SMALLINT, // 2
  151. 4, // 3
  152. NULL_CHAR, // 4
  153. NULL_CHAR, // 5
  154. NULL_CHAR, // 6
  155. SQL_NULLABLE, // 7
  156. SQL_FALSE, // 8
  157. SQL_SEARCHABLE, // 9
  158. SQL_TRUE, // 10
  159. SQL_TRUE, // 11
  160. SQL_FALSE, // 12
  161. NULL_CHAR, // 13
  162. NULL_INT, // 14
  163. NULL_INT, // 15
  164. SQL_SMALLINT, // 16
  165. NULL_INT, // 17
  166. 10, // 18
  167. NULL_INT // 19
  168.     },
  169.     { "INT", // 1
  170. SQL_INTEGER, // 2
  171. 9, // 3
  172. NULL_CHAR, // 4
  173. NULL_CHAR, // 5
  174. NULL_CHAR, // 6
  175. SQL_NULLABLE, // 7
  176. SQL_FALSE, // 8
  177. SQL_SEARCHABLE, // 9
  178. SQL_FALSE, // 10
  179. SQL_TRUE, // 11
  180. SQL_FALSE, // 12
  181. NULL_CHAR, // 13
  182. NULL_INT, // 14
  183. NULL_INT, // 15
  184. SQL_INTEGER, // 16
  185. NULL_INT, // 17
  186. 10, // 18
  187. NULL_INT // 19
  188.     },
  189.     { "INT UNSIGNED", // 1
  190. SQL_INTEGER, // 2
  191. 9, // 3
  192. NULL_CHAR, // 4
  193. NULL_CHAR, // 5
  194. NULL_CHAR, // 6
  195. SQL_NULLABLE, // 7
  196. SQL_FALSE, // 8
  197. SQL_SEARCHABLE, // 9
  198. SQL_TRUE, // 10
  199. SQL_TRUE, // 11
  200. SQL_FALSE, // 12
  201. NULL_CHAR, // 13
  202. NULL_INT, // 14
  203. NULL_INT, // 15
  204. SQL_INTEGER, // 16
  205. NULL_INT, // 17
  206. 10, // 18
  207. NULL_INT // 19
  208.     },
  209.     { "BIGINT", // 1
  210. SQL_BIGINT, // 2
  211. 19, // 3
  212. NULL_CHAR, // 4
  213. NULL_CHAR, // 5
  214. NULL_CHAR, // 6
  215. SQL_NULLABLE, // 7
  216. SQL_FALSE, // 8
  217. SQL_SEARCHABLE, // 9
  218. SQL_FALSE, // 10
  219. SQL_TRUE, // 11
  220. SQL_FALSE, // 12
  221. NULL_CHAR, // 13
  222. NULL_INT, // 14
  223. NULL_INT, // 15
  224. SQL_BIGINT, // 16
  225. NULL_INT, // 17
  226. 10, // 18
  227. NULL_INT // 19
  228.     },
  229.     { "BIGINT UNSIGNED", // 1
  230. SQL_BIGINT, // 2
  231. 19, // 3
  232. NULL_CHAR, // 4
  233. NULL_CHAR, // 5
  234. NULL_CHAR, // 6
  235. SQL_NULLABLE, // 7
  236. SQL_FALSE, // 8
  237. SQL_SEARCHABLE, // 9
  238. SQL_TRUE, // 10
  239. SQL_TRUE, // 11
  240. SQL_FALSE, // 12
  241. NULL_CHAR, // 13
  242. NULL_INT, // 14
  243. NULL_INT, // 15
  244. SQL_BIGINT, // 16
  245. NULL_INT, // 17
  246. 10, // 18
  247. NULL_INT // 19
  248.     },
  249.     { "REAL", // 1
  250. SQL_REAL, // 2
  251. 31, // 3
  252. NULL_CHAR, // 4
  253. NULL_CHAR, // 5
  254. NULL_CHAR, // 6
  255. SQL_NULLABLE, // 7
  256. SQL_FALSE, // 8
  257. SQL_SEARCHABLE, // 9
  258. SQL_FALSE, // 10
  259. SQL_TRUE, // 11
  260. SQL_FALSE, // 12
  261. NULL_CHAR, // 13
  262. NULL_INT, // 14
  263. NULL_INT, // 15
  264. SQL_REAL, // 16
  265. NULL_INT, // 17
  266. 2, // 18
  267. NULL_INT // 19
  268.     },
  269.     { "FLOAT", // 1
  270. SQL_DOUBLE, // 2
  271. 63, // 3
  272. NULL_CHAR, // 4
  273. NULL_CHAR, // 5
  274. NULL_CHAR, // 6
  275. SQL_NULLABLE, // 7
  276. SQL_FALSE, // 8
  277. SQL_SEARCHABLE, // 9
  278. SQL_FALSE, // 10
  279. SQL_TRUE, // 11
  280. SQL_FALSE, // 12
  281. NULL_CHAR, // 13
  282. NULL_INT, // 14
  283. NULL_INT, // 15
  284. SQL_DOUBLE, // 16
  285. NULL_INT, // 17
  286. 2, // 18
  287. NULL_INT // 19
  288.     },
  289.     { "DATETIME", // 1
  290. SQL_TYPE_TIMESTAMP, // 2
  291. 30, // 3
  292. NULL_CHAR, // 4
  293. NULL_CHAR, // 5
  294. NULL_CHAR, // 6
  295. SQL_NULLABLE, // 7
  296. SQL_FALSE, // 8
  297. SQL_SEARCHABLE, // 9
  298. SQL_FALSE, // 10
  299. SQL_TRUE, // 11
  300. SQL_FALSE, // 12
  301. NULL_CHAR, // 13
  302. NULL_INT, // 14
  303. NULL_INT, // 15
  304. SQL_DATETIME, // 16 XXX
  305. NULL_INT, // 17
  306. 2, // 18
  307. NULL_INT // 19
  308.     }
  309. };
  311. const unsigned
  312. typeinfoCount = sizeof(typeinfoList)/sizeof(typeinfoList[0]);
  314. void
  315. Exec_query_sys::execImpl(Ctx& ctx, Ctl& ctl)
  316. {
  317.     const Code& code = getCode();
  318.     Data& data = getData();
  319.     Ndb* const ndb = ndbObject();
  320.     NdbDictionary::Dictionary* ndbDictionary = ndb->getDictionary();
  321.     if (ndbDictionary == 0) {
  322. ctx.pushStatus(ndb, "getDictionary");
  323. return;
  324.     }
  325.     if (code.m_sysId == DictSys::OdbcTypeinfo || code.m_sysId == DictSys::Dual) {
  326. data.m_rowPos = 0; // at first entry
  327. return;
  328.     }
  329.     if (code.m_sysId == DictSys::OdbcTables || code.m_sysId == DictSys::OdbcColumns || code.m_sysId == DictSys::OdbcPrimarykeys) {
  330. // take all objects
  331. if (ndbDictionary->listObjects(data.m_objectList) == -1) {
  332.     ctx.pushStatus(ndb, "listObjects");
  333.     return;
  334. }
  335. data.m_tablePos = 0; // at first entry
  336. data.m_attrPos = 0;
  337. data.m_keyPos = 0;
  338. return;
  339.     }
  340.     ctx_assert(false);
  341. }
  343. static bool
  344. isNdbTable(const NdbDictionary::Dictionary::List::Element& element)
  345. {
  346.     switch (element.type) {
  347.     //case NdbDictionary::Object::SystemTable:
  348.     case NdbDictionary::Object::UserTable:
  349.     case NdbDictionary::Object::UniqueHashIndex:
  350.     case NdbDictionary::Object::HashIndex:
  351.     case NdbDictionary::Object::UniqueOrderedIndex:
  352.     case NdbDictionary::Object::OrderedIndex:
  353. return true;
  354.     default:
  355. break;
  356.     }
  357.     return false;
  358. }
  361. bool
  362. Exec_query_sys::fetchImpl(Ctx &ctx, Ctl& ctl)
  363. {
  364.     const Code& code = getCode();
  365.     Data& data = getData();
  366.     Ndb* const ndb = ndbObject();
  367.     NdbDictionary::Dictionary* ndbDictionary = ndb->getDictionary();
  368.     if (ndbDictionary == 0) {
  369. ctx.pushStatus(ndb, "getDictionary");
  370. return false;
  371.     }
  372.     if (code.m_sysId == DictSys::OdbcTypeinfo) {
  373. if (data.m_rowPos >= typeinfoCount) {
  374.     return false;
  375. }
  376. SqlRow& row = data.m_sqlRow;
  377. const Typeinfo& typeinfo = typeinfoList[data.m_rowPos++];
  378. for (unsigned i = 1; i <= code.m_attrCount; i++) {
  379.     SqlField& f = data.m_sqlRow.getEntry(i);
  380.     switch (1 + code.m_attrId[i]) {
  381.     case 1:
  382. if (typeinfo.m_type_name == NULL_CHAR)
  383.     f.sqlNull(true);
  384. else
  385.     f.sqlVarchar(typeinfo.m_type_name, SQL_NTS);
  386. break;
  387.     case 2:
  388. if (typeinfo.m_data_type == NULL_INT)
  389.     f.sqlNull(true);
  390. else
  391.     f.sqlInteger(typeinfo.m_data_type);
  392. break;
  393.     case 3:
  394. if (typeinfo.m_column_size == NULL_INT)
  395.     f.sqlNull(true);
  396. else
  397.     f.sqlInteger(typeinfo.m_column_size);
  398. break;
  399.     case 4:
  400. if (typeinfo.m_literal_prefix == NULL_CHAR)
  401.     f.sqlNull(true);
  402. else
  403.     f.sqlVarchar(typeinfo.m_literal_prefix, SQL_NTS);
  404. break;
  405.     case 5:
  406. if (typeinfo.m_literal_suffix == NULL_CHAR)
  407.     f.sqlNull(true);
  408. else
  409.     f.sqlVarchar(typeinfo.m_literal_suffix, SQL_NTS);
  410. break;
  411.     case 6:
  412. if (typeinfo.m_create_params == NULL_CHAR)
  413.     f.sqlNull(true);
  414. else
  415.     f.sqlVarchar(typeinfo.m_create_params, SQL_NTS);
  416. break;
  417.     case 7:
  418. if (typeinfo.m_nullable == NULL_INT)
  419.     f.sqlNull(true);
  420. else
  421.     f.sqlInteger(typeinfo.m_nullable);
  422. break;
  423.     case 8:
  424. if (typeinfo.m_case_sensitive == NULL_INT)
  425.     f.sqlNull(true);
  426. else
  427.     f.sqlInteger(typeinfo.m_case_sensitive);
  428. break;
  429.     case 9:
  430. if (typeinfo.m_searchable == NULL_INT)
  431.     f.sqlNull(true);
  432. else
  433.     f.sqlInteger(typeinfo.m_searchable);
  434. break;
  435.     case 10:
  436. if (typeinfo.m_unsigned_attribute == NULL_INT)
  437.     f.sqlNull(true);
  438. else
  439.     f.sqlInteger(typeinfo.m_unsigned_attribute);
  440. break;
  441.     case 11:
  442. if (typeinfo.m_fixed_prec_scale == NULL_INT)
  443.     f.sqlNull(true);
  444. else
  445.     f.sqlInteger(typeinfo.m_fixed_prec_scale);
  446. break;
  447.     case 12:
  448. if (typeinfo.m_auto_unique_value == NULL_INT)
  449.     f.sqlNull(true);
  450. else
  451.     f.sqlInteger(typeinfo.m_auto_unique_value);
  452. break;
  453.     case 13:
  454. if (typeinfo.m_local_type_name == NULL_CHAR)
  455.     f.sqlNull(true);
  456. else
  457.     f.sqlVarchar(typeinfo.m_local_type_name, SQL_NTS);
  458. break;
  459.     case 14:
  460. if (typeinfo.m_minimum_scale == NULL_INT)
  461.     f.sqlNull(true);
  462. else
  463.     f.sqlInteger(typeinfo.m_minimum_scale);
  464. break;
  465.     case 15:
  466. if (typeinfo.m_maximum_scale == NULL_INT)
  467.     f.sqlNull(true);
  468. else
  469.     f.sqlInteger(typeinfo.m_maximum_scale);
  470. break;
  471.     case 16:
  472. if (typeinfo.m_sql_data_type == NULL_INT)
  473.     f.sqlNull(true);
  474. else
  475.     f.sqlInteger(typeinfo.m_sql_data_type);
  476. break;
  477.     case 17:
  478. if (typeinfo.m_sql_datetime_sub == NULL_INT)
  479.     f.sqlNull(true);
  480. else
  481.     f.sqlInteger(typeinfo.m_sql_datetime_sub);
  482. break;
  483.     case 18:
  484. if (typeinfo.m_sql_datetime_sub == NULL_INT)
  485.     f.sqlNull(true);
  486. else
  487.     f.sqlInteger(typeinfo.m_sql_datetime_sub);
  488. break;
  489.     case 19:
  490. if (typeinfo.m_interval_precision == NULL_INT)
  491.     f.sqlNull(true);
  492. else
  493.     f.sqlInteger(typeinfo.m_interval_precision);
  494. break;
  495.     default:
  496. ctx_assert(false);
  497. break;
  498.     }
  499. }
  500. return true;
  501.     }
  502.     if (code.m_sysId == DictSys::OdbcTables) {
  503. if (data.m_tablePos >= data.m_objectList.count) {
  504.     return false;
  505. }
  506. NdbDictionary::Dictionary::List::Element& element = data.m_objectList.elements[data.m_tablePos++];
  507. for (unsigned i = 1; i <= code.m_attrCount; i++) {
  508.     SqlField& f = data.m_sqlRow.getEntry(i);
  509.     switch (1 + code.m_attrId[i]) {
  510.     case 1: // TABLE_CAT
  511. f.sqlNull(true);
  512. break;
  513.     case 2: // TABLE_SCHEM
  514. f.sqlNull(true);
  515. break;
  516.     case 3: // TABLE_NAME
  517. f.sqlVarchar(element.name, SQL_NTS);
  518. break;
  519.     case 4: { // TABLE_TYPE
  520. if (element.type == NdbDictionary::Object::SystemTable)
  521.     f.sqlVarchar("SYSTEM TABLE", SQL_NTS);
  522. else if (element.type == NdbDictionary::Object::UserTable)
  523.     f.sqlVarchar("TABLE", SQL_NTS);
  524. else if (element.type == NdbDictionary::Object::UniqueHashIndex)
  525.     f.sqlVarchar("UNIQUE HASH INDEX", SQL_NTS);
  526. else if (element.type == NdbDictionary::Object::HashIndex)
  527.     f.sqlVarchar("HASH INDEX", SQL_NTS);
  528. else if (element.type == NdbDictionary::Object::UniqueOrderedIndex)
  529.     f.sqlVarchar("UNIQUE INDEX", SQL_NTS);
  530. else if (element.type == NdbDictionary::Object::OrderedIndex)
  531.     f.sqlVarchar("INDEX", SQL_NTS);
  532. else if (element.type == NdbDictionary::Object::IndexTrigger)
  533.     f.sqlVarchar("INDEX TRIGGER", SQL_NTS);
  534. else if (element.type == NdbDictionary::Object::SubscriptionTrigger)
  535.     f.sqlVarchar("SUBSCRIPTION TRIGGER", SQL_NTS);
  536. else if (element.type == NdbDictionary::Object::ReadOnlyConstraint)
  537.     f.sqlVarchar("READ ONLY CONSTRAINT", SQL_NTS);
  538. else
  539.     f.sqlVarchar("UNKNOWN", SQL_NTS);
  540. }
  541. break;
  542.     case 5: // REMARKS
  543. f.sqlNull(true);
  544. break;
  545.     default:
  546. ctx_assert(false);
  547. break;
  548.     }
  549. }
  550. return true;
  551.     }
  552.     if (code.m_sysId == DictSys::OdbcColumns) {
  553. if (data.m_tablePos >= data.m_objectList.count) {
  554.     return false;
  555. }
  556. const NdbDictionary::Dictionary::List::Element& element = data.m_objectList.elements[data.m_tablePos];
  557. unsigned nattr;
  558. const NdbDictionary::Table* ndbTable;
  559. nattr = 0;
  560. if (isNdbTable(element)) {
  561.     ndbTable = ndbDictionary->getTable(element.name);
  562.     if (ndbTable == 0) {
  563. ctx.pushStatus(ndbDictionary->getNdbError(), "getTable %s", element.name);
  564. return false;
  565.     }
  566.     nattr = ndbTable->getNoOfColumns();
  567. }
  568. while (data.m_attrPos >= nattr) {
  569.     if (++data.m_tablePos >= data.m_objectList.count) {
  570. return false;
  571.     }
  572.     const NdbDictionary::Dictionary::List::Element& element = data.m_objectList.elements[data.m_tablePos];
  573.     nattr = 0;
  574.     if (isNdbTable(element)) {
  575. ndbTable = ndbDictionary->getTable(element.name);
  576. if (ndbTable == 0) {
  577.     ctx.pushStatus(ndbDictionary->getNdbError(), "getTable %s", element.name);
  578.     return false;
  579. }
  580. data.m_attrPos = 0;
  581. nattr = ndbTable->getNoOfColumns();
  582.     }
  583. }
  584. int attrId = data.m_attrPos++;
  585. const NdbDictionary::Column* ndbColumn = ndbTable->getColumn(attrId);
  586. if (ndbColumn == 0) {
  587.     ctx.pushStatus(ndbDictionary->getNdbError(), "getColumn %s.%d", ndbTable->getName(), attrId);
  588.     return false;
  589. }
  590. SqlType sqlType(ctx, ndbColumn);
  591. if (! ctx.ok())
  592.     return false;
  593. const char* p;
  594. for (unsigned i = 1; i <= code.m_attrCount; i++) {
  595.     SqlField& f = data.m_sqlRow.getEntry(i);
  596.     switch (1 + code.m_attrId[i]) {
  597.     case 1: // TABLE_CAT
  598. f.sqlNull(true);
  599. break;
  600.     case 2: // TABLE_SCHEM
  601. f.sqlNull(true);
  602. break;
  603.     case 3: // TABLE_NAME
  604. f.sqlVarchar(ndbTable->getName(), SQL_NTS);
  605. break;
  606.     case 4: // COLUMN_NAME
  607. f.sqlVarchar(ndbColumn->getName(), SQL_NTS);
  608. break;
  609.     case 5: // DATA_TYPE
  610. f.sqlInteger(sqlType.type());
  611. break;
  612.     case 6: // TYPE_NAME
  613. f.sqlVarchar(sqlType.typeName(), SQL_NTS);
  614. break;
  615.     case 7: // COLUMN_SIZE
  616. f.sqlInteger(sqlType.displaySize());
  617. break;
  618.     case 8: // BUFFER_LENGTH
  619. f.sqlInteger(sqlType.size());
  620. break;
  621.     case 9: // DECIMAL_DIGITS
  622. if (sqlType.type() == SqlType::Char)
  623.     f.sqlNull(true);
  624. else
  625.     f.sqlInteger(0);
  626. break;
  627.     case 10: // NUM_PREC_RADIX
  628. if (sqlType.type() == SqlType::Integer || sqlType.type() == SqlType::Bigint)
  629.     f.sqlInteger(10);
  630. else
  631.     f.sqlNull(true);
  632. break;
  633.     case 11: // NULLABLE
  634. if (sqlType.nullable())
  635.     f.sqlInteger(SQL_NULLABLE);
  636. else
  637.     f.sqlInteger(SQL_NO_NULLS);
  638. break;
  639.     case 12: // REMARKS
  640. f.sqlNull(true);
  641. break;
  642.     case 13: // COLUMN_DEF
  643. if ((p = ndbColumn->getDefaultValue()) != 0)
  644.     f.sqlVarchar(p, SQL_NTS);
  645. else
  646.     f.sqlNull(true);
  647. break;
  648.     case 14: // SQL_DATA_TYPE
  649. f.sqlInteger(sqlType.type());
  650. break;
  651.     case 15: // SQL_DATETIME_SUB
  652. f.sqlNull(true);
  653. break;
  654.     case 16: // CHAR_OCTET_LENGTH
  655. if (sqlType.type() == SqlType::Char)
  656.     f.sqlInteger(sqlType.length());
  657. else
  658.     f.sqlNull(true);
  659. break;
  660.     case 17: // ORDINAL_POSITION
  661. f.sqlInteger(1 + attrId);
  662. break;
  663.     case 18: // IS_NULLABLE
  664. if (sqlType.nullable())
  665.     f.sqlVarchar("YES", SQL_NTS);
  666. else
  667.     f.sqlVarchar("NO", SQL_NTS);
  668. break;
  669. break;
  670.     default:
  671. ctx_assert(false);
  672. break;
  673.     }
  674. }
  675. return true;
  676.     }
  677.     if (code.m_sysId == DictSys::OdbcPrimarykeys) {
  678. if (data.m_tablePos >= data.m_objectList.count) {
  679.     return false;
  680. }
  681. NdbDictionary::Dictionary::List::Element& element = data.m_objectList.elements[data.m_tablePos];
  682. unsigned nkeys;
  683. const NdbDictionary::Table* ndbTable;
  684. nkeys = 0;
  685. if (isNdbTable(element)) {
  686.     ndbTable = ndbDictionary->getTable(element.name);
  687.     if (ndbTable == 0) {
  688. ctx.pushStatus(ndbDictionary->getNdbError(), "getTable %s", element.name);
  689. return false;
  690.     }
  691.     nkeys = ndbTable->getNoOfPrimaryKeys();
  692. }
  693. while (data.m_keyPos >= nkeys) {
  694.     if (++data.m_tablePos >= data.m_objectList.count) {
  695. return false;
  696.     }
  697.     NdbDictionary::Dictionary::List::Element& element = data.m_objectList.elements[data.m_tablePos];
  698.     nkeys = 0;
  699.     if (isNdbTable(element)) {
  700. ndbTable = ndbDictionary->getTable(element.name);
  701. if (ndbTable == 0) {
  702.     ctx.pushStatus(ndbDictionary->getNdbError(), "getTable %s", element.name);
  703.     return false;
  704. }
  705. data.m_keyPos = 0;
  706. nkeys = ndbTable->getNoOfPrimaryKeys();
  707.     }
  708. }
  709. unsigned keyPos = data.m_keyPos++;
  710. const char* keyName = ndbTable->getPrimaryKey(keyPos);
  711. if (keyName == 0)
  712.     keyName = "?";
  713. for (unsigned i = 1; i <= code.m_attrCount; i++) {
  714.     SqlField& f = data.m_sqlRow.getEntry(i);
  715.     switch (1 + code.m_attrId[i]) {
  716.     case 1: // TABLE_CAT
  717. f.sqlNull(true);
  718. break;
  719.     case 2: // TABLE_SCHEM
  720. f.sqlNull(true);
  721. break;
  722.     case 3: // TABLE_NAME
  723. f.sqlVarchar(ndbTable->getName(), SQL_NTS);
  724. break;
  725.     case 4: // COLUMN_NAME
  726. f.sqlVarchar(keyName, SQL_NTS);
  727. break;
  728.     case 5: // KEY_SEQ
  729. f.sqlInteger(1 + keyPos);
  730. break;
  731.     case 6: // PK_NAME
  732. f.sqlNull(true);
  733. break;
  734.     default:
  735. ctx_assert(false);
  736. break;
  737.     }
  738. }
  739. return true;
  740.     }
  741.     if (code.m_sysId == DictSys::Dual) {
  742. if (data.m_rowPos > 0) {
  743.     return false;
  744. }
  745. data.m_rowPos++;
  746. for (unsigned i = 1; i <= code.m_attrCount; i++) {
  747.     SqlField& f = data.m_sqlRow.getEntry(i);
  748.     switch (1 + code.m_attrId[i]) {
  749.     case 1: // DUMMY
  750. f.sqlVarchar("X", 1);
  751. break;
  752.     default:
  753. ctx_assert(false);
  754. break;
  755.     }
  756. }
  757. return true;
  758.     }
  759.     ctx_assert(false);
  760.     return false;
  761. }