?? qsql_odbc.cpp
字號:
static QVariant qGetDoubleData(SQLHANDLE hStmt, int column){ SQLDOUBLE dblbuf; QSQLLEN lengthIndicator = 0; SQLRETURN r = SQLGetData(hStmt, column+1, SQL_C_DOUBLE, (SQLPOINTER)&dblbuf, 0, &lengthIndicator); if ((r != SQL_SUCCESS && r != SQL_SUCCESS_WITH_INFO) || lengthIndicator == SQL_NULL_DATA) return QVariant(QVariant::Double); return (double) dblbuf;}static QVariant qGetBigIntData(SQLHANDLE hStmt, int column){ SQLBIGINT lngbuf = 0; QSQLLEN lengthIndicator = 0; SQLRETURN r = SQLGetData(hStmt, column+1, SQL_C_SBIGINT, (SQLPOINTER) &lngbuf, 0, &lengthIndicator); if ((r != SQL_SUCCESS && r != SQL_SUCCESS_WITH_INFO) || lengthIndicator == SQL_NULL_DATA) return QVariant(QVariant::LongLong); return QVariant(qint64(lngbuf));}// creates a QSqlField from a valid hStmt generated// by SQLColumns. The hStmt has to point to a valid position.static QSqlField qMakeFieldInfo(const SQLHANDLE hStmt, const QODBCDriverPrivate* p){ QString fname = qGetStringData(hStmt, 3, -1, p->unicode); int type = qGetIntData(hStmt, 4).toInt(); // column type QSqlField f(fname, qDecodeODBCType(type, p)); int required = qGetIntData(hStmt, 10).toInt(); // nullable-flag // required can be SQL_NO_NULLS, SQL_NULLABLE or SQL_NULLABLE_UNKNOWN if (required == SQL_NO_NULLS) f.setRequired(true); else if (required == SQL_NULLABLE) f.setRequired(false); // else we don't know QVariant var = qGetIntData(hStmt, 6); f.setLength(var.isNull() ? -1 : var.toInt()); // column size var = qGetIntData(hStmt, 8).toInt(); f.setPrecision(var.isNull() ? -1 : var.toInt()); // precision f.setSqlType(type); return f;}static QSqlField qMakeFieldInfo(const QODBCPrivate* p, int i ){ SQLSMALLINT colNameLen; SQLSMALLINT colType; QSQLULEN colSize; SQLSMALLINT colScale; SQLSMALLINT nullable; SQLRETURN r = SQL_ERROR; SQLTCHAR colName[COLNAMESIZE]; r = SQLDescribeCol(p->hStmt, i+1, colName, (SQLSMALLINT)COLNAMESIZE, &colNameLen, &colType, &colSize, &colScale, &nullable); if (r != SQL_SUCCESS) { qSqlWarning(QString::fromLatin1("qMakeField: Unable to describe column %1").arg(i), p); return QSqlField(); }#ifdef UNICODE QString qColName((const QChar*)colName, colNameLen);#else QString qColName = QString::fromLocal8Bit((const char*)colName);#endif // nullable can be SQL_NO_NULLS, SQL_NULLABLE or SQL_NULLABLE_UNKNOWN int required = -1; if (nullable == SQL_NO_NULLS) { required = 1; } else if (nullable == SQL_NULLABLE) { required = 0; } QVariant::Type type = qDecodeODBCType(colType, p); QSqlField f(qColName, type); f.setSqlType(colType); f.setLength(colSize == 0 ? -1 : int(colSize)); f.setPrecision(colScale == 0 ? -1 : int(colScale)); if (nullable == SQL_NO_NULLS) f.setRequired(true); else if (nullable == SQL_NULLABLE) f.setRequired(false); // else we don't know return f;}bool QODBCDriverPrivate::setConnectionOptions(const QString& connOpts){ // Set any connection attributes const QStringList opts(connOpts.split(QLatin1Char(';'), QString::SkipEmptyParts)); SQLRETURN r = SQL_SUCCESS; for (int i = 0; i < opts.count(); ++i) { const QString tmp(opts.at(i)); int idx; if ((idx = tmp.indexOf(QLatin1Char('='))) == -1) { qWarning("QODBCDriver::open: Illegal connect option value '%s'", tmp.toLocal8Bit().constData()); continue; } const QString opt(tmp.left(idx)); const QString val(tmp.mid(idx + 1).simplified()); SQLUINTEGER v = 0; r = SQL_SUCCESS; if (opt == QLatin1String("SQL_ATTR_ACCESS_MODE")) { if (val == QLatin1String("SQL_MODE_READ_ONLY")) { v = SQL_MODE_READ_ONLY; } else if (val == QLatin1String("SQL_MODE_READ_WRITE")) { v = SQL_MODE_READ_WRITE; } else { qWarning("QODBCDriver::open: Unknown option value '%s'", val.toLocal8Bit().constData()); continue; } r = SQLSetConnectAttr(hDbc, SQL_ATTR_ACCESS_MODE, (SQLPOINTER) v, 0); } else if (opt == QLatin1String("SQL_ATTR_CONNECTION_TIMEOUT")) { v = val.toUInt(); r = SQLSetConnectAttr(hDbc, SQL_ATTR_CONNECTION_TIMEOUT, (SQLPOINTER) v, 0); } else if (opt == QLatin1String("SQL_ATTR_LOGIN_TIMEOUT")) { v = val.toUInt(); r = SQLSetConnectAttr(hDbc, SQL_ATTR_LOGIN_TIMEOUT, (SQLPOINTER) v, 0); } else if (opt == QLatin1String("SQL_ATTR_CURRENT_CATALOG")) { val.utf16(); // 0 terminate r = SQLSetConnectAttr(hDbc, SQL_ATTR_CURRENT_CATALOG,#ifdef UNICODE (SQLWCHAR*) val.unicode(),#else (SQLCHAR*) val.toLatin1().constData(),#endif SQL_NTS); } else if (opt == QLatin1String("SQL_ATTR_METADATA_ID")) { if (val == QLatin1String("SQL_TRUE")) { v = SQL_TRUE; } else if (val == QLatin1String("SQL_FALSE")) { v = SQL_FALSE; } else { qWarning("QODBCDriver::open: Unknown option value '%s'", val.toLocal8Bit().constData()); continue; } r = SQLSetConnectAttr(hDbc, SQL_ATTR_METADATA_ID, (SQLPOINTER) v, 0); } else if (opt == QLatin1String("SQL_ATTR_PACKET_SIZE")) { v = val.toUInt(); r = SQLSetConnectAttr(hDbc, SQL_ATTR_PACKET_SIZE, (SQLPOINTER) v, 0); } else if (opt == QLatin1String("SQL_ATTR_TRACEFILE")) { val.utf16(); // 0 terminate r = SQLSetConnectAttr(hDbc, SQL_ATTR_TRACEFILE,#ifdef UNICODE (SQLWCHAR*) val.unicode(),#else (SQLCHAR*) val.toLatin1().constData(),#endif SQL_NTS); } else if (opt == QLatin1String("SQL_ATTR_TRACE")) { if (val == QLatin1String("SQL_OPT_TRACE_OFF")) { v = SQL_OPT_TRACE_OFF; } else if (val == QLatin1String("SQL_OPT_TRACE_ON")) { v = SQL_OPT_TRACE_ON; } else { qWarning("QODBCDriver::open: Unknown option value '%s'", val.toLocal8Bit().constData()); continue; } r = SQLSetConnectAttr(hDbc, SQL_ATTR_TRACE, (SQLPOINTER) v, 0);#ifndef Q_ODBC_VERSION_2 } else if (opt == QLatin1String("SQL_ATTR_CONNECTION_POOLING")) { if (val == QLatin1String("SQL_CP_OFF")) v = SQL_CP_OFF; else if (val == QLatin1String("SQL_CP_ONE_PER_DRIVER")) v = SQL_CP_ONE_PER_DRIVER; else if (val == QLatin1String("SQL_CP_ONE_PER_HENV")) v = SQL_CP_ONE_PER_HENV; else if (val == QLatin1String("SQL_CP_DEFAULT")) v = SQL_CP_DEFAULT; else { qWarning("QODBCDriver::open: Unknown option value '%s'", val.toLocal8Bit().constData()); continue; } r = SQLSetConnectAttr(hDbc, SQL_ATTR_CONNECTION_POOLING, (SQLPOINTER)v, 0); } else if (opt == QLatin1String("SQL_ATTR_CP_MATCH")) { if (val == QLatin1String("SQL_CP_STRICT_MATCH")) v = SQL_CP_STRICT_MATCH; else if (val == QLatin1String("SQL_CP_RELAXED_MATCH")) v = SQL_CP_RELAXED_MATCH; else if (val == QLatin1String("SQL_CP_MATCH_DEFAULT")) v = SQL_CP_MATCH_DEFAULT; else { qWarning("QODBCDriver::open: Unknown option value '%s'", val.toLocal8Bit().constData()); continue; } r = SQLSetConnectAttr(hDbc, SQL_ATTR_CP_MATCH, (SQLPOINTER)v, 0);#endif } else { qWarning("QODBCDriver::open: Unknown connection attribute '%s'", opt.toLocal8Bit().constData()); } if (r != SQL_SUCCESS && r != SQL_SUCCESS_WITH_INFO) qSqlWarning(QString::fromLatin1("QODBCDriver::open: Unable to set connection attribute'%1'").arg( opt), this); } return true;}void QODBCDriverPrivate::splitTableQualifier(const QString & qualifier, QString &catalog, QString &schema, QString &table){ if (!useSchema) { table = qualifier; return; } QStringList l = qualifier.split(QLatin1Char('.')); if (l.count() > 3) return; // can't possibly be a valid table qualifier int i = 0, n = l.count(); if (n == 1) { table = qualifier; } else { for (QStringList::Iterator it = l.begin(); it != l.end(); ++it) { if (n == 3) { if (i == 0) { catalog = *it; } else if (i == 1) { schema = *it; } else if (i == 2) { table = *it; } } else if (n == 2) { if (i == 0) { schema = *it; } else if (i == 1) { table = *it; } } i++; } }}////////////////////////////////////////////////////////////////////////////QODBCResult::QODBCResult(const QODBCDriver * db, QODBCDriverPrivate* p): QSqlResult(db){ d = new QODBCPrivate(); d->hEnv = p->hEnv; d->hDbc = p->hDbc; d->unicode = p->unicode; d->useSchema = p->useSchema; d->sql_char_type = p->sql_char_type; d->sql_varchar_type = p->sql_varchar_type; d->sql_longvarchar_type = p->sql_longvarchar_type;}QODBCResult::~QODBCResult(){ if (d->hStmt && driver()->isOpen()) { SQLRETURN r = SQLFreeHandle(SQL_HANDLE_STMT, d->hStmt); if (r != SQL_SUCCESS) qSqlWarning(QLatin1String("QODBCDriver: Unable to free statement handle ") + QString::number(r), d); } delete d;}bool QODBCResult::reset (const QString& query){ setActive(false); setAt(QSql::BeforeFirstRow); SQLRETURN r; d->rInf.clear(); d->fieldCache.clear(); d->fieldCacheIdx = 0; // Always reallocate the statement handle - the statement attributes // are not reset if SQLFreeStmt() is called which causes some problems. if (d->hStmt) { r = SQLFreeHandle(SQL_HANDLE_STMT, d->hStmt); if (r != SQL_SUCCESS) { qSqlWarning(QLatin1String("QODBCResult::reset: Unable to free statement handle"), d); return false; } } r = SQLAllocHandle(SQL_HANDLE_STMT, d->hDbc, &d->hStmt); if (r != SQL_SUCCESS) { qSqlWarning(QLatin1String("QODBCResult::reset: Unable to allocate statement handle"), d); return false; } if (isForwardOnly()) { r = SQLSetStmtAttr(d->hStmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER)SQL_CURSOR_FORWARD_ONLY, SQL_IS_UINTEGER); } else { r = SQLSetStmtAttr(d->hStmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER)SQL_CURSOR_STATIC, SQL_IS_UINTEGER); } if (r != SQL_SUCCESS && r != SQL_SUCCESS_WITH_INFO) { setLastError(qMakeError(QCoreApplication::translate("QODBCResult", "QODBCResult::reset: Unable to set 'SQL_CURSOR_STATIC' as statement attribute. " "Please check your ODBC driver configuration"), QSqlError::StatementError, d)); return false; }#ifdef UNICODE r = SQLExecDirect(d->hStmt, (SQLWCHAR*) query.unicode(), (SQLINTEGER) query.length());#else QByteArray query8 = query.toLocal8Bit(); r = SQLExecDirect(d->hStmt, (SQLCHAR*) query8.constData(), (SQLINTEGER) query8.length());#endif if (r != SQL_SUCCESS && r != SQL_SUCCESS_WITH_INFO) { setLastError(qMakeError(QCoreApplication::translate("QODBCResult", "Unable to execute statement"), QSqlError::StatementError, d)); return false; } SQLSMALLINT count; r = SQLNumResultCols(d->hStmt, &count); if (count) { setSelect(true); for (int i = 0; i < count; ++i) { d->rInf.append(qMakeFieldInfo(d, i)); } d->fieldCache.resize(count); } else { setSelect(false); } setActive(true); return true;}bool QODBCResult::fetch(int i){ if (isForwardOnly() && i < at()) return false; if (i == at()) return true; d->clearValues(); int actualIdx = i + 1; if (actualIdx <= 0) { setAt(QSql::BeforeFirstRow); return false; } SQLRETURN r; if (isForwardOnly()) { bool ok = true; while (ok && i > at()) ok = fetchNext(); return ok; } else { r = SQLFetchScroll(d->hStmt, SQL_FETCH_ABSOLUTE, actualIdx); } if (r != SQL_SUCCESS){ return false; }?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -