Many hyperlinks are disabled.
Use anonymous login
to enable hyperlinks.
Overview
| Comment: | More work in progress. |
|---|---|
| Downloads: | Tarball | ZIP archive |
| Timelines: | family | ancestors | descendants | both | virtualTables |
| Files: | files | file ages | folders |
| SHA1: |
8a682d20dc6e68a8472cff27a56fa49b |
| User & Date: | mistachkin 2013-06-15 02:46:54.820 |
Context
|
2013-06-18
| ||
| 06:07 | More work on input/output marshalling for the sqlite3_index_info structure. Also, refactoring to allow better portability to the .NET Compact Framework. check-in: ea5335378e user: mistachkin tags: virtualTables | |
|
2013-06-15
| ||
| 02:46 | More work in progress. check-in: 8a682d20dc user: mistachkin tags: virtualTables | |
|
2013-06-13
| ||
| 22:49 | Complete most of the initial virtual table module base class. Some fixes to types for marshalling. check-in: df6776ec88 user: mistachkin tags: virtualTables | |
Changes
Changes to System.Data.SQLite/SQLiteModuleBase.cs.
| ︙ | ︙ | |||
307 308 309 310 311 312 313 |
private UnsafeNativeMethods.sqlite3_index_constraint_usage constraintUsage;
}
///////////////////////////////////////////////////////////////////////////
public sealed class SQLiteIndexInputs
{
| > > > > > > > > | > > > > > > > | > > > | | > > > > > > > > | > > > > > > > | > > > > > > > > | > > > > > > > > > > > > > > > > | > > > > > > > > > > > > > > > > > > > > > > | > > > > > > > | > > > | 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 |
private UnsafeNativeMethods.sqlite3_index_constraint_usage constraintUsage;
}
///////////////////////////////////////////////////////////////////////////
public sealed class SQLiteIndexInputs
{
public SQLiteIndexInputs(int nConstraint, int nOrderBy)
{
constraints = new SQLiteIndexConstraint[nConstraint];
orderBys = new SQLiteIndexOrderBy[nOrderBy];
}
///////////////////////////////////////////////////////////////////////
private SQLiteIndexConstraint[] constraints;
public SQLiteIndexConstraint[] Constraints
{
get { return constraints; }
}
///////////////////////////////////////////////////////////////////////
private SQLiteIndexOrderBy[] orderBys;
public SQLiteIndexOrderBy[] OrderBys
{
get { return orderBys; }
}
}
///////////////////////////////////////////////////////////////////////////
public sealed class SQLiteIndexOutputs
{
public SQLiteIndexOutputs(int nConstraint)
{
constraintUsages = new SQLiteIndexConstraintUsage[nConstraint];
}
///////////////////////////////////////////////////////////////////////
private SQLiteIndexConstraintUsage[] constraintUsages;
public SQLiteIndexConstraintUsage[] ConstraintUsages
{
get { return constraintUsages; }
}
///////////////////////////////////////////////////////////////////////
private int idxNum; /* Number used to identify the index */
public int IdxNum
{
get { return idxNum; }
set { idxNum = value; }
}
///////////////////////////////////////////////////////////////////////
private string idxStr; /* String, possibly obtained from sqlite3_malloc */
public string IdxStr
{
get { return idxStr; }
set { idxStr = value; }
}
///////////////////////////////////////////////////////////////////////
private int needToFreeIdxStr; /* Free idxStr using sqlite3_free() if true */
public int NeedToFreeIdxStr
{
get { return needToFreeIdxStr; }
set { needToFreeIdxStr = value; }
}
///////////////////////////////////////////////////////////////////////
private int orderByConsumed; /* True if output is already ordered */
public int OrderByConsumed
{
get { return orderByConsumed; }
set { orderByConsumed = value; }
}
///////////////////////////////////////////////////////////////////////
private double estimatedCost; /* Estimated cost of using this index */
public double EstimatedCost
{
get { return estimatedCost; }
set { estimatedCost = value; }
}
}
///////////////////////////////////////////////////////////////////////////
public sealed class SQLiteIndex
{
public SQLiteIndex(int nConstraint, int nOrderBy)
{
inputs = new SQLiteIndexInputs(nConstraint, nOrderBy);
outputs = new SQLiteIndexOutputs(nConstraint);
}
///////////////////////////////////////////////////////////////////////
private SQLiteIndexInputs inputs;
public SQLiteIndexInputs Inputs
{
get { return inputs; }
}
///////////////////////////////////////////////////////////////////////
private SQLiteIndexOutputs outputs;
public SQLiteIndexOutputs Outputs
{
get { return outputs; }
}
}
///////////////////////////////////////////////////////////////////////////
public class SQLiteVirtualTableCursor
{
public SQLiteVirtualTableCursor(
|
| ︙ | ︙ | |||
359 360 361 362 363 364 365 |
public interface ISQLiteNativeModule
{
// https://www.sqlite.org/vtab.html
SQLiteErrorCode xCreate(IntPtr pDb, IntPtr pAux, int argc, ref IntPtr[] argv, ref IntPtr pVtab, ref IntPtr pError);
SQLiteErrorCode xConnect(IntPtr pDb, IntPtr pAux, int argc, ref IntPtr[] argv, ref IntPtr pVtab, ref IntPtr pError);
| | | 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 |
public interface ISQLiteNativeModule
{
// https://www.sqlite.org/vtab.html
SQLiteErrorCode xCreate(IntPtr pDb, IntPtr pAux, int argc, ref IntPtr[] argv, ref IntPtr pVtab, ref IntPtr pError);
SQLiteErrorCode xConnect(IntPtr pDb, IntPtr pAux, int argc, ref IntPtr[] argv, ref IntPtr pVtab, ref IntPtr pError);
SQLiteErrorCode xBestIndex(IntPtr pVtab, IntPtr pIndex);
SQLiteErrorCode xDisconnect(IntPtr pVtab);
SQLiteErrorCode xDestroy(IntPtr pVtab);
SQLiteErrorCode xOpen(IntPtr pVtab, ref IntPtr pCursor);
SQLiteErrorCode xClose(IntPtr pCursor);
SQLiteErrorCode xFilter(IntPtr pCursor, int idxNum, IntPtr idxStr, int argc, IntPtr[] argv);
SQLiteErrorCode xNext(IntPtr pCursor);
bool xEof(IntPtr pCursor);
|
| ︙ | ︙ | |||
404 405 406 407 408 409 410 |
SQLiteErrorCode Column(SQLiteVirtualTableCursor cursor, SQLiteContext context, int index);
SQLiteErrorCode RowId(SQLiteVirtualTableCursor cursor, ref long rowId);
SQLiteErrorCode Update(SQLiteValue[] values, ref long rowId);
SQLiteErrorCode Begin();
SQLiteErrorCode Sync();
SQLiteErrorCode Commit();
SQLiteErrorCode Rollback();
| | | 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 |
SQLiteErrorCode Column(SQLiteVirtualTableCursor cursor, SQLiteContext context, int index);
SQLiteErrorCode RowId(SQLiteVirtualTableCursor cursor, ref long rowId);
SQLiteErrorCode Update(SQLiteValue[] values, ref long rowId);
SQLiteErrorCode Begin();
SQLiteErrorCode Sync();
SQLiteErrorCode Commit();
SQLiteErrorCode Rollback();
bool FindFunction(int nArg, string zName, ref SQLiteFunction function, ref IntPtr pClientData);
SQLiteErrorCode Rename(string zNew);
SQLiteErrorCode Savepoint(int iSavepoint);
SQLiteErrorCode Release(int iSavepoint);
SQLiteErrorCode RollbackTo(int iSavepoint);
}
///////////////////////////////////////////////////////////////////////////
|
| ︙ | ︙ | |||
665 666 667 668 669 670 671 672 673 674 675 676 677 678 |
SQLiteValue[] result = new SQLiteValue[values.Length];
for (int index = 0; index < result.Length; index++)
result[index] = new SQLiteValue(values[index]);
return result;
}
#endregion
///////////////////////////////////////////////////////////////////////
#region Public Constructors
public SQLiteModuleBase()
| > > > > > > > > > > > > > > > > > > > > > > > | 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 |
SQLiteValue[] result = new SQLiteValue[values.Length];
for (int index = 0; index < result.Length; index++)
result[index] = new SQLiteValue(values[index]);
return result;
}
///////////////////////////////////////////////////////////////////////
private static UnsafeNativeMethods.sqlite3_index_info IndexFromIntPtr(
IntPtr pIndex
)
{
if (pIndex == IntPtr.Zero)
return new UnsafeNativeMethods.sqlite3_index_info();
return new UnsafeNativeMethods.sqlite3_index_info();
}
///////////////////////////////////////////////////////////////////////
private static void IndexOutputsToIntPtr(
UnsafeNativeMethods.sqlite3_index_info index,
SQLiteIndexOutputs indexOutputs
)
{
}
#endregion
///////////////////////////////////////////////////////////////////////
#region Public Constructors
public SQLiteModuleBase()
|
| ︙ | ︙ | |||
936 937 938 939 940 941 942 |
return SQLiteErrorCode.Error;
}
///////////////////////////////////////////////////////////////////////
public SQLiteErrorCode xBestIndex(
IntPtr pVtab,
| | > > > > | > > > > > > > > | 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 |
return SQLiteErrorCode.Error;
}
///////////////////////////////////////////////////////////////////////
public SQLiteErrorCode xBestIndex(
IntPtr pVtab,
IntPtr pIndex
)
{
try
{
if (BestIndex(null) == SQLiteErrorCode.Ok)
{
return SQLiteErrorCode.Ok;
}
}
catch (Exception e) /* NOTE: Must catch ALL. */
{
SetTableError(pVtab, e.ToString());
}
return SQLiteErrorCode.Error;
}
///////////////////////////////////////////////////////////////////////
public SQLiteErrorCode xDisconnect(
IntPtr pVtab
)
|
| ︙ | ︙ | |||
1335 1336 1337 1338 1339 1340 1341 |
)
{
try
{
SQLiteFunction function = null;
if (FindFunction(
| | | 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 |
)
{
try
{
SQLiteFunction function = null;
if (FindFunction(
nArg, StringFromUtf8IntPtr(zName), ref function,
ref pClientData))
{
if (function != null)
{
callback = function.ScalarCallback;
return true;
}
|
| ︙ | ︙ | |||
1550 1551 1552 1553 1554 1555 1556 1557 1558 1559 1560 1561 1562 1563 |
///////////////////////////////////////////////////////////////////////
public abstract SQLiteErrorCode Rollback();
///////////////////////////////////////////////////////////////////////
public abstract bool FindFunction(
string zName,
ref SQLiteFunction function,
ref IntPtr pClientData
);
///////////////////////////////////////////////////////////////////////
| > | 1674 1675 1676 1677 1678 1679 1680 1681 1682 1683 1684 1685 1686 1687 1688 |
///////////////////////////////////////////////////////////////////////
public abstract SQLiteErrorCode Rollback();
///////////////////////////////////////////////////////////////////////
public abstract bool FindFunction(
int nArg,
string zName,
ref SQLiteFunction function,
ref IntPtr pClientData
);
///////////////////////////////////////////////////////////////////////
|
| ︙ | ︙ |
Changes to System.Data.SQLite/SQLiteModuleNoop.cs.
| ︙ | ︙ | |||
219 220 221 222 223 224 225 226 227 228 229 230 231 232 |
CheckDisposed();
throw new NotImplementedException();
}
///////////////////////////////////////////////////////////////////////
public override bool FindFunction(
string zName,
ref SQLiteFunction function,
ref IntPtr pClientData
)
{
CheckDisposed();
throw new NotImplementedException();
| > | 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 |
CheckDisposed();
throw new NotImplementedException();
}
///////////////////////////////////////////////////////////////////////
public override bool FindFunction(
int nArg,
string zName,
ref SQLiteFunction function,
ref IntPtr pClientData
)
{
CheckDisposed();
throw new NotImplementedException();
|
| ︙ | ︙ |
Changes to System.Data.SQLite/UnsafeNativeMethods.cs.
| ︙ | ︙ | |||
1651 1652 1653 1654 1655 1656 1657 |
///////////////////////////////////////////////////////////////////////////
#if !PLATFORM_COMPACTFRAMEWORK
[UnmanagedFunctionPointer(CallingConvention.Cdecl)]
#endif
public delegate SQLiteErrorCode xBestIndex(
IntPtr pVtab,
| | | 1651 1652 1653 1654 1655 1656 1657 1658 1659 1660 1661 1662 1663 1664 1665 |
///////////////////////////////////////////////////////////////////////////
#if !PLATFORM_COMPACTFRAMEWORK
[UnmanagedFunctionPointer(CallingConvention.Cdecl)]
#endif
public delegate SQLiteErrorCode xBestIndex(
IntPtr pVtab,
IntPtr pIndex
);
///////////////////////////////////////////////////////////////////////////
#if !PLATFORM_COMPACTFRAMEWORK
[UnmanagedFunctionPointer(CallingConvention.Cdecl)]
#endif
|
| ︙ | ︙ | |||
1958 1959 1960 1961 1962 1963 1964 1965 1966 1967 1968 1969 1970 1971 1972 1973 |
internal struct sqlite3_index_info
{
/* Inputs */
public int nConstraint; /* Number of entries in aConstraint */
[MarshalAs(UnmanagedType.LPArray, SizeParamIndex = 0)]
public sqlite3_index_constraint[] aConstraint;
public int nOrderBy;
public sqlite3_index_orderby[] aOrderBy;
/* Outputs */
public sqlite3_index_constraint_usage[] aConstraintUsage;
public int idxNum; /* Number used to identify the index */
public string idxStr; /* String, possibly obtained from sqlite3_malloc */
public int needToFreeIdxStr; /* Free idxStr using sqlite3_free() if true */
public int orderByConsumed; /* True if output is already ordered */
public double estimatedCost; /* Estimated cost of using this index */
}
| > > | 1958 1959 1960 1961 1962 1963 1964 1965 1966 1967 1968 1969 1970 1971 1972 1973 1974 1975 |
internal struct sqlite3_index_info
{
/* Inputs */
public int nConstraint; /* Number of entries in aConstraint */
[MarshalAs(UnmanagedType.LPArray, SizeParamIndex = 0)]
public sqlite3_index_constraint[] aConstraint;
public int nOrderBy;
[MarshalAs(UnmanagedType.LPArray, SizeParamIndex = 2)]
public sqlite3_index_orderby[] aOrderBy;
/* Outputs */
[MarshalAs(UnmanagedType.LPArray, SizeParamIndex = 0)]
public sqlite3_index_constraint_usage[] aConstraintUsage;
public int idxNum; /* Number used to identify the index */
public string idxStr; /* String, possibly obtained from sqlite3_malloc */
public int needToFreeIdxStr; /* Free idxStr using sqlite3_free() if true */
public int orderByConsumed; /* True if output is already ordered */
public double estimatedCost; /* Estimated cost of using this index */
}
|
| ︙ | ︙ |