Many hyperlinks are disabled.
Use anonymous login
to enable hyperlinks.
Overview
| Comment: | For the xCreate/xConnect/xDisconnect/xDestroy methods of the SQLiteModule class, refactor out the common code into private methods. Changes to comments. |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | trunk |
| Files: | files | file ages | folders |
| SHA1: |
9e6f8b4fca1ef61e53689044ff16ddb6 |
| User & Date: | mistachkin 2013-07-05 01:31:12 |
Context
|
2013-07-05
| ||
| 02:10 | Adjustments to the #if directives related to the vtshim extension module. check-in: f680c43ce0 user: mistachkin tags: trunk | |
| 01:31 | For the xCreate/xConnect/xDisconnect/xDestroy methods of the SQLiteModule class, refactor out the common code into private methods. Changes to comments. check-in: 9e6f8b4fca user: mistachkin tags: trunk | |
|
2013-07-04
| ||
| 20:44 | Adjustments to the cleanup of several tests. check-in: a48ea4b8d9 user: mistachkin tags: trunk | |
Changes
Changes to System.Data.SQLite/SQLiteModule.cs.
5518 5519 5520 5521 5522 5523 5524 5525 5526 5527 5528 5529 5530 5531 .... 6110 6111 6112 6113 6114 6115 6116 6117 6118 6119 6120 6121 6122 6123 6124 6125 .... 6430 6431 6432 6433 6434 6435 6436 6437 6438 6439 6440 6441 6442 6443 6444 6445 6446 6447 6448 6449 6450 6451 6452 6453 6454 6455 6456 6457 6458 6459 6460 6461 6462 6463 6464 6465 6466 6467 6468 6469 6470 6471 6472 6473 6474 6475 6476 6477 6478 6479 6480 6481 .... 6505 6506 6507 6508 6509 6510 6511 6512 6513 6514 6515 6516 6517 6518 6519 6520 6521 6522 6523 6524 6525 6526 6527 6528 6529 6530 6531 6532 6533 6534 6535 6536 6537 6538 6539 6540 6541 6542 6543 6544 6545 6546 6547 6548 6549 6550 6551 6552 6553 6554 6555 6556 .... 6604 6605 6606 6607 6608 6609 6610 6611 6612 6613 6614 6615 6616 6617 6618 6619 6620 6621 6622 6623 6624 6625 6626 6627 6628 6629 6630 6631 6632 6633 6634 6635 6636 6637 6638 6639 6640 6641 6642 6643 6644 6645 6646 6647 6648 6649 6650 6651 6652 6653 6654 6655 6656 6657 6658 6659 6660 .... 6664 6665 6666 6667 6668 6669 6670 6671 6672 6673 6674 6675 6676 6677 6678 6679 6680 6681 6682 6683 6684 6685 6686 6687 6688 6689 6690 6691 6692 6693 6694 6695 6696 6697 6698 6699 6700 6701 6702 6703 6704 6705 6706 6707 6708 6709 6710 6711 6712 6713 6714 6715 6716 6717 6718 6719 6720 .... 6944 6945 6946 6947 6948 6949 6950 6951 6952 6953 6954 6955 6956 6957 6958 .... 7263 7264 7265 7266 7267 7268 7269 7270 7271 7272 7273 7274 7275 7276 7277 |
xRollbackTo);
return newModule;
}
///////////////////////////////////////////////////////////////////////
#region Static Error Handling Helper Methods
/// <summary>
/// Arranges for the specified error message to be placed into the
/// zErrMsg field of a sqlite3_vtab derived structure, freeing the
/// existing error message, if any.
/// </summary>
/// <param name="module">
................................................................................
#endregion
///////////////////////////////////////////////////////////////////////
#region Function Lookup Methods
/// <summary>
/// Deterimines the key that should be used to identify and store the
/// function instance for the virtual table (i.e. to be returned via
/// the <see cref="ISQLiteNativeModule.xFindFunction" /> method).
/// </summary>
/// <param name="argumentCount">
/// The number of arguments to the virtual table function.
/// </param>
/// <param name="name">
/// The name of the virtual table function.
/// </param>
................................................................................
IntPtr pAux,
int argc,
IntPtr argv,
ref IntPtr pVtab,
ref IntPtr pError
)
{
try
{
string fileName = SQLiteString.StringFromUtf8IntPtr(
UnsafeNativeMethods.sqlite3_db_filename(pDb, IntPtr.Zero));
using (SQLiteConnection connection = new SQLiteConnection(
pDb, fileName, false))
{
SQLiteVirtualTable table = null;
string error = null;
if (Create(connection, pAux,
SQLiteString.StringArrayFromUtf8SizeAndIntPtr(argc,
argv), ref table, ref error) == SQLiteErrorCode.Ok)
{
if (table != null)
{
pVtab = TableToIntPtr(table);
return SQLiteErrorCode.Ok;
}
else
{
pError = SQLiteString.Utf8IntPtrFromString(
"no table was created");
}
}
else
{
pError = SQLiteString.Utf8IntPtrFromString(error);
}
}
}
catch (Exception e) /* NOTE: Must catch ALL. */
{
pError = SQLiteString.Utf8IntPtrFromString(e.ToString());
}
return SQLiteErrorCode.Error;
}
///////////////////////////////////////////////////////////////////////
/// <summary>
/// See the <see cref="ISQLiteNativeModule.xConnect" /> method.
/// </summary>
................................................................................
IntPtr pAux,
int argc,
IntPtr argv,
ref IntPtr pVtab,
ref IntPtr pError
)
{
try
{
string fileName = SQLiteString.StringFromUtf8IntPtr(
UnsafeNativeMethods.sqlite3_db_filename(pDb, IntPtr.Zero));
using (SQLiteConnection connection = new SQLiteConnection(
pDb, fileName, false))
{
SQLiteVirtualTable table = null;
string error = null;
if (Connect(connection, pAux,
SQLiteString.StringArrayFromUtf8SizeAndIntPtr(argc,
argv), ref table, ref error) == SQLiteErrorCode.Ok)
{
if (table != null)
{
pVtab = TableToIntPtr(table);
return SQLiteErrorCode.Ok;
}
else
{
pError = SQLiteString.Utf8IntPtrFromString(
"no table was created");
}
}
else
{
pError = SQLiteString.Utf8IntPtrFromString(error);
}
}
}
catch (Exception e) /* NOTE: Must catch ALL. */
{
pError = SQLiteString.Utf8IntPtrFromString(e.ToString());
}
return SQLiteErrorCode.Error;
}
///////////////////////////////////////////////////////////////////////
/// <summary>
/// See the <see cref="ISQLiteNativeModule.xBestIndex" /> method.
/// </summary>
................................................................................
/// <returns>
/// See the <see cref="ISQLiteNativeModule.xDisconnect" /> method.
/// </returns>
private SQLiteErrorCode xDisconnect(
IntPtr pVtab
)
{
try
{
SQLiteVirtualTable table = TableFromIntPtr(pVtab);
if (table != null)
{
if (Disconnect(table) == SQLiteErrorCode.Ok)
{
if (tables != null)
tables.Remove(pVtab);
return SQLiteErrorCode.Ok;
}
}
}
catch (Exception e) /* NOTE: Must catch ALL. */
{
//
// NOTE: At this point, there is no way to report the error
// condition back to the caller; therefore, use the
// logging facility instead.
//
try
{
if (LogExceptions)
{
SQLiteLog.LogMessage(SQLiteBase.COR_E_EXCEPTION,
String.Format(CultureInfo.CurrentCulture,
"Caught exception in \"xDisconnect\" method: {0}",
e)); /* throw */
}
}
catch
{
// do nothing.
}
}
finally
{
FreeTable(pVtab);
}
return SQLiteErrorCode.Error;
}
///////////////////////////////////////////////////////////////////////
/// <summary>
/// See the <see cref="ISQLiteNativeModule.xDestroy" /> method.
/// </summary>
................................................................................
/// <returns>
/// See the <see cref="ISQLiteNativeModule.xDestroy" /> method.
/// </returns>
private SQLiteErrorCode xDestroy(
IntPtr pVtab
)
{
try
{
SQLiteVirtualTable table = TableFromIntPtr(pVtab);
if (table != null)
{
if (Destroy(table) == SQLiteErrorCode.Ok)
{
if (tables != null)
tables.Remove(pVtab);
return SQLiteErrorCode.Ok;
}
}
}
catch (Exception e) /* NOTE: Must catch ALL. */
{
//
// NOTE: At this point, there is no way to report the error
// condition back to the caller; therefore, use the
// logging facility instead.
//
try
{
if (LogExceptions)
{
SQLiteLog.LogMessage(SQLiteBase.COR_E_EXCEPTION,
String.Format(CultureInfo.CurrentCulture,
"Caught exception in \"xDestroy\" method: {0}",
e)); /* throw */
}
}
catch
{
// do nothing.
}
}
finally
{
FreeTable(pVtab);
}
return SQLiteErrorCode.Error;
}
///////////////////////////////////////////////////////////////////////
/// <summary>
/// See the <see cref="ISQLiteNativeModule.xOpen" /> method.
/// </summary>
................................................................................
return Eof(cursor) ? 1 : 0;
}
catch (Exception e) /* NOTE: Must catch ALL. */
{
SetTableError(pVtab, e.ToString());
}
return 1;
}
///////////////////////////////////////////////////////////////////////
/// <summary>
/// See the <see cref="ISQLiteNativeModule.xColumn" /> method.
/// </summary>
................................................................................
}
}
catch (Exception e) /* NOTE: Must catch ALL. */
{
SetTableError(pVtab, e.ToString());
}
return 0;
}
///////////////////////////////////////////////////////////////////////
/// <summary>
/// See the <see cref="ISQLiteNativeModule.xRename" /> method.
/// </summary>
|
> > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > | | | < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < > | < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < > | < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < | < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < < | | |
5518 5519 5520 5521 5522 5523 5524 5525 5526 5527 5528 5529 5530 5531 5532 5533 5534 5535 5536 5537 5538 5539 5540 5541 5542 5543 5544 5545 5546 5547 5548 5549 5550 5551 5552 5553 5554 5555 5556 5557 5558 5559 5560 5561 5562 5563 5564 5565 5566 5567 5568 5569 5570 5571 5572 5573 5574 5575 5576 5577 5578 5579 5580 5581 5582 5583 5584 5585 5586 5587 5588 5589 5590 5591 5592 5593 5594 5595 5596 5597 5598 5599 5600 5601 5602 5603 5604 5605 5606 5607 5608 5609 5610 5611 5612 5613 5614 5615 5616 5617 5618 5619 5620 5621 5622 5623 5624 5625 5626 5627 5628 5629 5630 5631 5632 5633 5634 5635 5636 5637 5638 5639 5640 5641 5642 5643 5644 5645 5646 5647 5648 5649 5650 5651 5652 5653 5654 5655 5656 5657 5658 5659 5660 5661 5662 5663 5664 5665 5666 5667 5668 5669 5670 5671 5672 5673 5674 5675 5676 5677 5678 5679 5680 5681 5682 5683 5684 5685 5686 5687 5688 5689 5690 .... 6269 6270 6271 6272 6273 6274 6275 6276 6277 6278 6279 6280 6281 6282 6283 6284 6285 .... 6590 6591 6592 6593 6594 6595 6596 6597 6598 6599 6600 6601 6602 6603 6604 6605 .... 6629 6630 6631 6632 6633 6634 6635 6636 6637 6638 6639 6640 6641 6642 6643 6644 .... 6692 6693 6694 6695 6696 6697 6698 6699 6700 6701 6702 6703 6704 6705 6706 .... 6710 6711 6712 6713 6714 6715 6716 6717 6718 6719 6720 6721 6722 6723 6724 .... 6948 6949 6950 6951 6952 6953 6954 6955 6956 6957 6958 6959 6960 6961 6962 .... 7267 7268 7269 7270 7271 7272 7273 7274 7275 7276 7277 7278 7279 7280 7281 |
xRollbackTo);
return newModule;
}
///////////////////////////////////////////////////////////////////////
/// <summary>
/// Calls one of the virtual table initialization methods.
/// </summary>
/// <param name="create">
/// Non-zero to call the <see cref="ISQLiteManagedModule.Create" />
/// method; otherwise, the <see cref="ISQLiteManagedModule.Connect" />
/// method will be called.
/// </param>
/// <param name="pDb">
/// The native database connection handle.
/// </param>
/// <param name="pAux">
/// The original native pointer value that was provided to the
/// sqlite3_create_module(), sqlite3_create_module_v2() or
/// sqlite3_create_disposable_module() functions.
/// </param>
/// <param name="argc">
/// The number of arguments from the CREATE VIRTUAL TABLE statement.
/// </param>
/// <param name="argv">
/// The array of string arguments from the CREATE VIRTUAL TABLE
/// statement.
/// </param>
/// <param name="pVtab">
/// Upon success, this parameter must be modified to point to the newly
/// created native sqlite3_vtab derived structure.
/// </param>
/// <param name="pError">
/// Upon failure, this parameter must be modified to point to the error
/// message, with the underlying memory having been obtained from the
/// sqlite3_malloc() function.
/// </param>
/// <returns>
/// A standard SQLite return code.
/// </returns>
private SQLiteErrorCode CreateOrConnect(
bool create,
IntPtr pDb,
IntPtr pAux,
int argc,
IntPtr argv,
ref IntPtr pVtab,
ref IntPtr pError
)
{
try
{
string fileName = SQLiteString.StringFromUtf8IntPtr(
UnsafeNativeMethods.sqlite3_db_filename(pDb, IntPtr.Zero));
using (SQLiteConnection connection = new SQLiteConnection(
pDb, fileName, false))
{
SQLiteVirtualTable table = null;
string error = null;
if ((create && Create(connection, pAux,
SQLiteString.StringArrayFromUtf8SizeAndIntPtr(argc,
argv), ref table, ref error) == SQLiteErrorCode.Ok) ||
(!create && Connect(connection, pAux,
SQLiteString.StringArrayFromUtf8SizeAndIntPtr(argc,
argv), ref table, ref error) == SQLiteErrorCode.Ok))
{
if (table != null)
{
pVtab = TableToIntPtr(table);
return SQLiteErrorCode.Ok;
}
else
{
pError = SQLiteString.Utf8IntPtrFromString(
"no table was created");
}
}
else
{
pError = SQLiteString.Utf8IntPtrFromString(error);
}
}
}
catch (Exception e) /* NOTE: Must catch ALL. */
{
pError = SQLiteString.Utf8IntPtrFromString(e.ToString());
}
return SQLiteErrorCode.Error;
}
///////////////////////////////////////////////////////////////////////
/// <summary>
/// Calls one of the virtual table finalization methods.
/// </summary>
/// <param name="destroy">
/// Non-zero to call the <see cref="ISQLiteManagedModule.Destroy" />
/// method; otherwise, the
/// <see cref="ISQLiteManagedModule.Disconnect" /> method will be
/// called.
/// </param>
/// <param name="pVtab">
/// The native pointer to the sqlite3_vtab derived structure.
/// </param>
/// <returns>
/// A standard SQLite return code.
/// </returns>
private SQLiteErrorCode DestroyOrDisconnect(
bool destroy,
IntPtr pVtab
)
{
try
{
SQLiteVirtualTable table = TableFromIntPtr(pVtab);
if (table != null)
{
if ((destroy && (Destroy(table) == SQLiteErrorCode.Ok)) ||
(!destroy && (Disconnect(table) == SQLiteErrorCode.Ok)))
{
if (tables != null)
tables.Remove(pVtab);
return SQLiteErrorCode.Ok;
}
}
}
catch (Exception e) /* NOTE: Must catch ALL. */
{
//
// NOTE: At this point, there is no way to report the error
// condition back to the caller; therefore, use the
// logging facility instead.
//
try
{
if (LogExceptions)
{
/* throw */
SQLiteLog.LogMessage(SQLiteBase.COR_E_EXCEPTION,
String.Format(CultureInfo.CurrentCulture,
"Caught exception in \"{0}\" method: {1}",
destroy ? "xDestroy" : "xDisconnect", e));
}
}
catch
{
// do nothing.
}
}
finally
{
FreeTable(pVtab);
}
return SQLiteErrorCode.Error;
}
///////////////////////////////////////////////////////////////////////
#region Static Error Handling Helper Methods
/// <summary>
/// Arranges for the specified error message to be placed into the
/// zErrMsg field of a sqlite3_vtab derived structure, freeing the
/// existing error message, if any.
/// </summary>
/// <param name="module">
................................................................................
#endregion
///////////////////////////////////////////////////////////////////////
#region Function Lookup Methods
/// <summary>
/// Deterimines the key that should be used to identify and store the
/// <see cref="SQLiteFunction" /> object instance for the virtual table
/// (i.e. to be returned via the
/// <see cref="ISQLiteNativeModule.xFindFunction" /> method).
/// </summary>
/// <param name="argumentCount">
/// The number of arguments to the virtual table function.
/// </param>
/// <param name="name">
/// The name of the virtual table function.
/// </param>
................................................................................
IntPtr pAux,
int argc,
IntPtr argv,
ref IntPtr pVtab,
ref IntPtr pError
)
{
return CreateOrConnect(
true, pDb, pAux, argc, argv, ref pVtab, ref pError);
}
///////////////////////////////////////////////////////////////////////
/// <summary>
/// See the <see cref="ISQLiteNativeModule.xConnect" /> method.
/// </summary>
................................................................................
IntPtr pAux,
int argc,
IntPtr argv,
ref IntPtr pVtab,
ref IntPtr pError
)
{
return CreateOrConnect(
false, pDb, pAux, argc, argv, ref pVtab, ref pError);
}
///////////////////////////////////////////////////////////////////////
/// <summary>
/// See the <see cref="ISQLiteNativeModule.xBestIndex" /> method.
/// </summary>
................................................................................
/// <returns>
/// See the <see cref="ISQLiteNativeModule.xDisconnect" /> method.
/// </returns>
private SQLiteErrorCode xDisconnect(
IntPtr pVtab
)
{
return DestroyOrDisconnect(false, pVtab);
}
///////////////////////////////////////////////////////////////////////
/// <summary>
/// See the <see cref="ISQLiteNativeModule.xDestroy" /> method.
/// </summary>
................................................................................
/// <returns>
/// See the <see cref="ISQLiteNativeModule.xDestroy" /> method.
/// </returns>
private SQLiteErrorCode xDestroy(
IntPtr pVtab
)
{
return DestroyOrDisconnect(true, pVtab);
}
///////////////////////////////////////////////////////////////////////
/// <summary>
/// See the <see cref="ISQLiteNativeModule.xOpen" /> method.
/// </summary>
................................................................................
return Eof(cursor) ? 1 : 0;
}
catch (Exception e) /* NOTE: Must catch ALL. */
{
SetTableError(pVtab, e.ToString());
}
return 1; /* NOTE: On any error, return "no more rows". */
}
///////////////////////////////////////////////////////////////////////
/// <summary>
/// See the <see cref="ISQLiteNativeModule.xColumn" /> method.
/// </summary>
................................................................................
}
}
catch (Exception e) /* NOTE: Must catch ALL. */
{
SetTableError(pVtab, e.ToString());
}
return 0; /* NOTE: On any error, return "no such function". */
}
///////////////////////////////////////////////////////////////////////
/// <summary>
/// See the <see cref="ISQLiteNativeModule.xRename" /> method.
/// </summary>
|