[转]FastDb介绍(6)

一个类T的游标包含一个类T的实例，用来获得当前的记录。这就是为什么表类必须要有一个缺省构造函数(无参数的构造函数)而没有副作用。fastdb优化了从中获取记录，只从对象的固定部分复制记录。字符串本身并不复制，而是使相应的字段直接指向中。数组也是如此：他们的组件在中的表示根在应用程序中的表示是一样的（标量类型的数组或者标量组件的嵌套结构的数组）.

应用程序不能直接改变中的字符串和数据元素。当一个数组方法需要更新一个数组体时，先在内存中创建一个副本然后更新这个副本。如果程序员要更新字符串字段，他应该给这个指针赋一个新值，而不是直接修改里的字符串。对于字符串元素建议使用char const * 而不是char *，以使编译器可以检查对字符串的非法使用。

else//如果是其它节点，则让原来指向当前节点的指针，指向它的下一个节点，完成删除。如果要删除的节点不是头结点的话，由于curr是通过&entry->next更新的，所以要此时curr指向要删除的节点的上一个节点的next指针，而entry指向的是要当前要删除的指针，此时*curr=entry->next就相当于prev->next=entry->next，从而完成当前节点的删除。* *h保存表头结点的指针，*p指向当前结点的前一个结点，*s指向当前结点*/。

当更新记录后，的大小可能会增加。从而虚拟存储器的区域需要进行扩展。该重映射的后果之一就是，该区域的基地址可能发生变化，然后应用程序中保存的所有指针都变得无效。当区域重映象时fastdb自动更新所有打开的游标中的当前记录。因此，当一个更新时，程序员应该通过游标的->方法来访问记录字段，而不应该使用指针变量。

当前选择使用的内存可以通过reset()方法来释放。该方法自动的由select()、dbDatabase::commit()、dbDatabase::rollback()方法以及游标的销毁（destructor）函数调用，因此大多数情况下不需要显式调用reset()方法。

游标也可以通过引用来访问记录。at(dbReference<T>const& ref)方法把游标指向引用所指的记录。在这种情况下，选择将只包含一个记录，而next(),prev()方法将总是返回NULL。由于游标和引用在fastdb重视严格类型化的，所有必须的检查可以有编译器静态的进行而不需要动态类型检查。运行时唯一要进行的检查是对空引用的检查。游标中当前记录的对象标识符可以用currentId()方法获得。

可以限制select语句返回的记录的数目。游标类有两个方法setSelectionLimit(size_t lim)和unsetSelectionLimit()用来设置/取消查询返回的记录数的限制。在某些情况下，程序员可能只需要几个记录或者头几个记录，从而查询的执行时间和消耗的内存大小可以通过限制选择的大小来降低。但如果你指定了被选记录的排序方式，只选择k个记录的查询并不返回关键字最小的头k个记录，而是返回任意k个记录然后排序。

linux系统下文件锁的操作主要介绍posix标准提供的方法，函数fcntl为文件控制方法重载实现的一种。tee函数是在两个管道文件描述符之间复制数据，也是零拷贝操作，而它不消耗数据，原始数据仍可以用于后续操作，函数原型与返回值与splice类似，我们以一个可以同时输出数据到终端和文件的程序为例：。需要注意的是无名管道只能用低级文件编程库中的读写函数进行操作，如read和write，当我们向一个空管道执行read时，函数会阻塞，直到有数据写入才继续执行，同理对满的管道执行write也会进入阻塞状态。

template<class T>

dbReference<T> insert(T const& record);

该函数将在表的末尾插入一个记录然后返回该对象的引用。fastdb中插入的顺序是严格指定的因而应用程序可以使用表中记录排序方式的假定。因为应用程序大量使用引用在对象之间导航，有必要提供一个根对象，从这个对象开始进行引用遍历。这样一个根对象的一个可取候选者就是表中的第一个记录（也是表中最老的记录）.该记录可以通过不带参数执行select（）方法来访问。游标中的当前记录就是表中的第一条记录。

fastdb的c++API为引用类型定义了一个特殊的null变量，可以用null变量与引用比较或者赋给一个引用：

void update(dbReference<Contract> c) {

if (c != null) {

dbCursor<Contract>contract(dbCursorForUpdate);

contract.at(c);

contract->supplier = null;

}

}

在引入线程的操作系统中，不仅进程之间可以并发执行，而且在一个进程中的多个线程之间，亦可并发执行，因而使操作系统具有更好的并发性，从而能更有效地使 用系统资源和提高系统吞吐量。mpp 是对称结构，当执行一个查询时，该查询将被调度到集群中的每一个节点执行，这意味着一个包含 4 个节点的 mpp 集群和一个包含 400 个节点的 mpp 集群所支持的并发查询数量是相同的，也就是说，并发查询数量和集群节点数量无关，一般而言，当并发查询个数达到 20 左右时，整个系统的吞吐已经达到满负荷状态。在引入线程的操作系统中，不仅进程之间可以并发执行，而且多个线程之间也可以并发执行，从而使操作系统具有更好的并发性，提高了系统的吞吐量。

dbQueryq;

struct QueryParams {

intsalary;

int age;

int rank;

};

void open()

{

QueryParams* params = (QueryParams*)NULL;

q = "salary > ", params->salary, "and age < ",params->age, "and rank =", params->rank;

}

void find(int salary, int age, int rank)

{

QueryParamsparams;

params.salary = salary;

params.age = age;

params.rank = rank;

dbCursor<Person> cusor;

if (cursor.select(q, &params) > 0) {

do{

cout << cursor->name << NL;

} while (cursor.next());

}

}

在这个例子中open函数只为结构中的字段偏移绑定查询变量。然后再find函数中，指向带有参数的结构的真实的指针传递给select结构。find函数可以被多个线程并发执行而只有一个编译好的查询被所有这些线程使用。这种机制从版本2.25开始使用。

第4节. Database

dbDatabase类控制应用与的交互，进行并发访问的同步，事务处理，内存分配，出错处理...

dbDatabase对象的构造函数允许程序员制定一些参数。

dbDatabase(dbAccessType type = dbAllAccess,

size_t dbInitSize =dbDefaultInitDatabaseSize,

size_t dbExtensionQuantum =dbDefaultExtensionQuantum,

size_t dbInitIndexSize =dbDefaultInitIndexSize,

int nThreads = 1);

支持下面的访问类型：

Access type

Description

dbDatabase::dbReadOnly

Read only mode

dbDatabase::dbAllAccess

Normal mode

dbDatabase::dbConcurrentRead

Read only mode in which application can access the database concurrently with application updating the same database in dbConcurrentUpdate mode

dbDatabase::dbConcurrentUpdate

you can perform low-level updates of the database using the execute method.。the following example shows how to create a full database backup by using with format to overwrite any existing backups and create a new media set. then, the example backs up the transaction log. in a real-life situation, you would have to perform a series of regular log backups. for this example, the adventureworks2012 sample database is set to use the full recovery model.。"indy has a special component that solves the user interface freeze problem transparently. simply add one tidantifreeze anywhere in your application, and you can perform standard blocking indy calls in your program without the user interface being frozen.。

当已只读方式打开时，不能向添加新的类定义，不能改变已有的类的定义和索引。

在主要用只读模式访问而更新不应该长时间堵塞读操作的情况下应该同时使用dbConcurrentUpdate和dbConcurrentRead模式。在这种模式下更新可以与读访问并发执行（读将不会看到改变的数据直到事务提交）。只有在更新事务提交时，才会设置排他锁然后在当前对象索引自增改变(incremental change)之后马上释放掉。

事务串行化执行，事务只能一个接着一个地执行，而不能并发执行。它要求事务序列化执行，事务只能一个接着一个地执行，但不能并发执行。实际上，事务是解决多条sql执行执行过程的原子性、一致性、隔离性、持久性的整体解决方案，而事务分离水平则是并发控制的整体解决方案，其实际是综合利用各种类型的锁来解决并发问题。

注意！不要把dbConcurrentUpdate和dbConcurrentRead模式与其他模式混合使用，也不要在一个进程中同时使用他们（因此不能启动两个线程其中一个用dbConcurrentUpdate模式打开另一个用dbConcurrentRead模式）。在dbConcurrentUpdate模式下不要使用dbDatabase::precommit方法。（precommit方法主要作用是释放资源和解锁，但是不会同步到磁盘映射文件）。

dbInitSize参数指定了文件的初始大小。文件按照需要增长；设置初始大小只是为了减少重新分配空间（会占用很多时间）的次数。在当前fastdb的实现中该大小在每次扩展时至少加倍。该参数的缺省值为4兆字节。

本文来自电脑杂谈，转载请注明本文网址：
http://www.pc-fly.com/a/jisuanjixue/article-106153-6.html