1 files changed, 0 insertions, 130 deletions
diff --git a/ndb/src/old_files/client/odbc/executor/Exec_query_scan.cpp b/ndb/src/old_files/client/odbc/executor/Exec_query_scan.cpp
deleted file mode 100644
index 213dfdd616d..00000000000
--- a/ndb/src/old_files/client/odbc/executor/Exec_query_scan.cpp
+++ /dev/null
@@ -1,130 +0,0 @@
-/* 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;
-}