1 files changed, 130 insertions, 0 deletions
diff --git a/storage/ndb/src/old_files/client/odbc/executor/Exec_query_scan.cpp b/storage/ndb/src/old_files/client/odbc/executor/Exec_query_scan.cpp
new file mode 100644
index 00000000000..213dfdd616d
--- /dev/null
+++ b/storage/ndb/src/old_files/client/odbc/executor/Exec_query_scan.cpp
@@ -0,0 +1,130 @@
+/* Copyright (C) 2003 MySQL AB
+
+   This program is free software; you can redistribute it and/or modify
+   it under the terms of the GNU General Public License as published by
+   the Free Software Foundation; either version 2 of the License, or
+   (at your option) any later version.
+
+   This program is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+   GNU General Public License for more details.
+
+   You should have received a copy of the GNU General Public License
+   along with this program; if not, write to the Free Software
+   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
+
+#include <NdbApi.hpp>
+#include <NdbScanFilter.hpp>
+#include <common/StmtArea.hpp>
+#include <common/ResultArea.hpp>
+#include <codegen/Code_query_scan.hpp>
+#include <codegen/Code_table.hpp>
+
+#define startBuddyTransaction(x)	hupp(x)
+
+void
+Exec_query_scan::execImpl(Ctx& ctx, Ctl& ctl)
+{
+    const Code& code = getCode();
+    Data& data = getData();
+    Ndb* const ndb = ndbObject();
+    NdbConnection* const tcon = ndbConnection();
+    if (data.m_con != 0) {
+	data.m_con->stopScan();
+	ndb->closeTransaction(data.m_con);
+	data.m_con = 0;
+	data.m_op = 0;
+	ctx_log2(("scan closed at re-execute"));
+    }
+    data.m_con = ndb->startBuddyTransaction(tcon);
+    if (data.m_con == 0) {
+	ctx.pushStatus(ndb, tcon, 0, "startBuddyTransaction");
+	return;
+    }
+    data.m_op = data.m_con->getNdbOperation(code.m_tableName);
+    if (data.m_op == 0) {
+	ctx.pushStatus(ndb, data.m_con, 0, "getNdbOperation");
+	return;
+    }
+    if (! code.m_exclusive) {
+	if (data.m_op->openScanReadCommitted(data.m_parallel) == -1) {
+	    ctx.pushStatus(ndb, data.m_con, data.m_op, "openScanReadCommitted");
+	    return;
+	}
+    } else {
+	if (data.m_op->openScanExclusive(data.m_parallel) == -1) {
+	    ctx.pushStatus(ndb, data.m_con, data.m_op, "openScanExclusive");
+	    return;
+	}
+    }
+    if (m_interp == 0) {
+	// XXX unnecessary
+	if (data.m_op->interpret_exit_ok() == -1) {
+	    ctx.pushStatus(ndb, data.m_con, data.m_op, "interpret_exit_ok");
+	    return;
+	}
+    } else {
+	NdbScanFilter scanFilter(data.m_op);
+	scanFilter.begin(NdbScanFilter::AND);
+	ctl.m_scanFilter = &scanFilter;
+	m_interp->execInterp(ctx, ctl);
+	if (! ctx.ok())
+	    return;
+	scanFilter.end();
+    }
+    const SqlRow& sqlRow = data.sqlRow();
+    ctx_assert(sqlRow.count() == code.m_attrCount);
+    for (unsigned i = 1; i <= code.m_attrCount; i++) {
+	const NdbAttrId attrId = code.m_attrId[i];
+	SqlField& sqlField = sqlRow.getEntry(i);
+	char* addr = static_cast<char*>(sqlField.addr());
+	NdbRecAttr* recAttr = data.m_op->getValue(attrId, addr);
+	if (recAttr == 0) {
+	    ctx.pushStatus(ndb, data.m_con, data.m_op, "getValue attrId=%u", (unsigned)attrId);
+	    return;
+	}
+	data.m_recAttr[i] = recAttr;
+    }
+    if (code.m_attrCount == 0) {		// NDB requires one
+	(void)data.m_op->getValue((NdbAttrId)0);
+    }
+    if (data.m_con->executeScan() == -1) {
+	ctx.pushStatus(ndb, data.m_con, data.m_op, "executeScan");
+	return;
+    }
+    ctx_log2(("scan %s [%08x] started", ! code.m_exclusive ? "read" : "exclusive", (unsigned)this));
+    ctl.m_scanOp = data.m_op;
+}
+
+bool
+Exec_query_scan::fetchImpl(Ctx &ctx, Ctl& ctl)
+{
+    const Code& code = getCode();
+    Data& data = getData();
+    Ndb* const ndb = ndbObject();
+    int ret = data.m_con->nextScanResult();
+    if (ret != 0) {
+	if (ret == -1) {
+	    ctx.pushStatus(ndb, data.m_con, data.m_op, "nextScanResult");
+	}
+	data.m_con->stopScan();
+	ndb->closeTransaction(data.m_con);
+	data.m_con = 0;
+	data.m_op = 0;
+	ctx_log2(("scan [%08x] closed at last row", (unsigned)this));
+	return false;
+    }
+    // set null bits
+    const SqlRow& sqlRow = data.sqlRow();
+    ctx_assert(sqlRow.count() == code.m_attrCount);
+    for (unsigned i = 1; i <= code.m_attrCount; i++) {
+	NdbRecAttr* recAttr = data.m_recAttr[i];
+	int isNULL = recAttr->isNULL();
+	SqlField& sqlField = sqlRow.getEntry(i);
+	ctx_assert(isNULL == 0 || isNULL == 1);
+	sqlField.sqlNull(isNULL == 1);
+    }
+    stmtArea().incTuplesFetched();
+    return true;
+}