公开(公告)号：US06349310B1

公开(公告)日：2002-02-19

申请号：US09347998

申请日：1999-07-06

申请人： Johannes Klein ,  Robbert C. Van der Linden ,  Raj K. Rathee

发明人： Johannes Klein ,  Robbert C. Van der Linden ,  Raj K. Rathee

IPC分类号： G06F1200

CPC分类号： G06F17/30339

摘要： In a database management system, when the table to be accessed by a statement is partitioned, a respective partition scan operator is used to access rows of each respective database table partition. A fan out operator receives requests from a calling application to access rows from table, and responds by sending requests for rows to the partition scan operators. It receives rows of the table from the partition scan operators and sends the received rows of the database table to another node in the execution tree. Each of the partition scan operators responds to the requests for rows by returning to the fan out operator qualifying rows, if any, from the corresponding table partition. If the statement being executed includes an embedded delete or update operation, the qualifying rows are deleted or updated at the same time that the qualifying rows are returned to the fan out operator. Control is returned to the calling application only after all rows deleted or updated by the partition scan operators have been sent to the calling application. When the statement being executed is a streaming mode query, the fan out operator sends non-blocking requests to the partition scan operators so that when one access to one partition is blocked, rows from another partition are processed.

摘要翻译： 在数据库管理系统中，当要由语句访问的表被分区时，相应的分区扫描运算符用于访问每个相应的数据库表分区的行。 扇出操作员接收来自呼叫应用程序的请求以从表访问行，并通过向行扫描运算符发送行请求来进行响应。 它从分区扫描运算符接收表的行，并将接收到的数据库表的行发送到执行树中的另一个节点。 每个分区扫描运算符通过返回到扇出操作符来对相应表分区中的行（如果有的话）进行限定来响应行的请求。 如果正在执行的语句包括嵌入式删除或更新操作，则在合格行返回到扇出操作符的同时删除或更新合格行。 只有在分区扫描运算符已删除或更新的所有行已发送到调用应用程序之后，才将控制权返回给调用应用程序。 当正在执行的语句是流模式查询时，扇出操作员向分区扫描运算符发送非阻塞请求，以便当阻止对一个分区的访问时，处理来自另一个分区的行。

公开(公告)号：US06453313B1

公开(公告)日：2002-09-17

申请号：US09347996

申请日：1999-07-06

申请人： Johannes Klein ,  Robbert C. Van der Linden ,  Raj K. Rathee

发明人： Johannes Klein ,  Robbert C. Van der Linden ,  Raj K. Rathee

IPC分类号： G06F1730

CPC分类号： G06F17/30421 ,  G06F17/30516 ,  Y10S707/99933 ,  Y10S707/99952

摘要： The SQL compiler and SQL executor in a database management system are extended to execute statements for dequeuing rows from a database table and statements that both updating tuples and return those tuples to a calling application. During execution of a select statement that includes an embedded update or delete operation, a table access operator accesses a defined range of rows in a database table. The table access operator receives from a calling application a request for rows dequeued from the database table. The table access operator responds to the requests for rows by returning to the calling application qualifying rows, if any, from the database table and also by performing the embedded delete or update operation. The SQL executor returns control to the calling application only after all rows deleted or updated by the table access operator have been sent to the calling application.

摘要翻译： 数据库管理系统中的SQL编译器和SQL执行程序被扩展为执行语句，用于从数据库表中将行排队，并且更新元组并将这些元组返回给调用应用程序的语句。 在执行包含嵌入式更新或删除操作的select语句期间，表访问运算符访问数据库表中定义的行范围。 表访问运算符从调用应用程序接收对从数据库表排队的行的请求。 表访问操作符通过返回到调用应用程序来响应行的请求，从数据库表中限定行（如果有的话），还通过执行嵌入式删除或更新操作。 只有在由表访问运算符删除或更新的所有行已发送到调用应用程序之后，SQL执行程序将控制权返回给调用应用程序。

公开(公告)号：US06604102B2

公开(公告)日：2003-08-05

申请号：US09997823

申请日：2001-11-29

申请人： Johannes Klein ,  Robbert C. Van der Linden ,  Raj K. Rathee ,  Hansjorg Zeller

发明人： Johannes Klein ,  Robbert C. Van der Linden ,  Raj K. Rathee ,  Hansjorg Zeller

IPC分类号： G06F1730

CPC分类号： G06F17/30492 ,  G06F17/30516 ,  Y10S707/99933 ,  Y10S707/99934 ,  Y10S707/99935

摘要： The SQL compiler and SQL executor in a database management system are extended to process queries requiring streaming mode processing of data stored in a table. A scan operator performs table access functions during execution of the streaming mode query. The scan operator first performs an initial scan to access rows in a specified database table, and then performs a delta scan to access new rows added to the table, as well as rows modified by other queries. The scan operator continues to process new data added to the table until the initiating user or application closes the associated cursor. A set of data structures are provided to keep track of active scan operators, including a session control block that includes fields for keeping track of whether the scan operator is performing an initial scan or a delta scan. The session control block also includes, for streaming mode scan operators, a delta scan list of new and modified rows to be processed in the delta scan. When a transaction terminates, any streaming mode scan operators whose operation was suspended because of rows locked by the transaction are automatically rescheduled for execution.

公开(公告)号：US06339772B1

公开(公告)日：2002-01-15

申请号：US09347997

申请日：1999-07-06

申请人： Johannes Klein ,  Robbert C. Van der Linden ,  Raj K. Rathee ,  Hansjorg Zeller

发明人： Johannes Klein ,  Robbert C. Van der Linden ,  Raj K. Rathee ,  Hansjorg Zeller

IPC分类号： G06F1730

CPC分类号： G06F17/30492 ,  G06F17/30516 ,  Y10S707/99933 ,  Y10S707/99934 ,  Y10S707/99935

摘要： The SQL compiler and SQL executor in a database management system are extended to process queries requiring streaming mode processing of data stored in a table. A scan operator performs table access functions during execution of the streaming mode query. The scan operator first performs an initial scan to access rows in a specified database table, and then performs a delta scan to access new rows added to the table, as well as rows modified by other queries. The scan operator continues to process new data added to the table until the initiating user or application closes the associated cursor. A set of data structures are provided to keep track of active scan operators, including a session control block that includes fields for keeping track of whether the scan operator is performing an initial scan or a delta scan. The session control block also includes, for streaming mode scan operators, a delta scan list of new and modified rows to be processed in the delta scan. When a transaction terminates, any streaming mode scan operators whose operation was suspended because of rows locked by the transaction are automatically rescheduled for execution.

摘要翻译： 数据库管理系统中的SQL编译器和SQL执行器被扩展到处理需要对存储在表中的数据进行流模式处理的查询。 扫描运算符在执行流模式查询期间执行表访问功能。 扫描操作员首先执行初始扫描以访问指定数据库表中的行，然后执行增量扫描以访问添加到表中的新行以及其他查询修改的行。 扫描运算符继续处理添加到表中的新数据，直到启动用户或应用程序关闭相关联的光标。 提供了一组数据结构来跟踪主动扫描运算符，包括会话控制块，其包括用于跟踪扫描运算符是执行初始扫描还是增量扫描的字段。 对于流模式扫描运算符，会话控制块还包括在delta扫描中要处理的新行和修改行的增量扫描列表。 当事务终止时，由于事务锁定行被暂停运行的任何流模式扫描运算符都将自动重新计划执行。

公开(公告)号：US06397227B1

公开(公告)日：2002-05-28

申请号：US09347994

申请日：1999-07-06

申请人： Johannes Klein ,  Robbert C. Van der Linden ,  Raj K. Rathee ,  Anoop Sharma

发明人： Johannes Klein ,  Robbert C. Van der Linden ,  Raj K. Rathee ,  Anoop Sharma

IPC分类号： G06F1730

CPC分类号： G06F17/30516 ,  G06F17/30348 ,  G06F17/30377 ,  G06F17/30418 ,  Y10S707/99938

摘要： A database management system includes an execution engine that, upon rollback of an aborted transaction, has the ability to set fields of the rows that are updated or deleted by the transaction prior to aborting. In particular, when a select, update or delete statement includes a “set on rollback” clause, the respective table access operator of the execution engine modifies the “before image” of each row that is stored by the transaction log manager. The modified before image includes the field updates specified by the set on rollback clause. If a transaction associated with the statement aborts, when the transaction log manager restores the before images of each row that was deleted or updated by the transaction, the restored before images include the field updates specified by the set on rollback clause.

摘要翻译： 数据库管理系统包括一个执行引擎，在中止事务的回滚之后，能够在中止之前设置事务更新或删除的行的字段。 特别地，当select，update或delete语句包括“set on rollback”子句时，执行引擎的相应表访问操作符修改由事务日志管理器存储的每一行的“before image”。 修改后的图像包括由rollback子句中指定的字段更新。 如果与该语句关联的事务中止，则当事务日志管理器恢复由事务删除或更新的每一行的先前图像时，恢复的映像之前包括由rollback子句设置的字段更新。

公开(公告)号：US06304873B1

公开(公告)日：2001-10-16

申请号：US09347995

申请日：1999-07-06

申请人： Johannes Klein ,  Robbert C. Van der Linden ,  Raj K. Rathee

发明人： Johannes Klein ,  Robbert C. Van der Linden ,  Raj K. Rathee

IPC分类号： G06F1730

CPC分类号： G06F17/30421 ,  G06F17/30362 ,  G06F17/30516 ,  Y10S707/99938 ,  Y10S707/99952

摘要： A database management system is extended to process SQL statements so as to skip over rows that are locked in conflicting modes. Normally, a table access operator is blocked when it attempts to access a row that is locked in a conflicting mode, such as a write lock mode, that is inconsistent with the read or write access required by the operator. Generally, the lock in the conflicting mode will be held by a transaction other than the transaction associated with the operator in question. When the SQL statement being executed uses the “skip conflict” syntax provided by the present invention, the operator skips over rows that are locked in conflicting modes, which would otherwise cause the operator to suspend operation. Furthermore, if the operator is operating in streaming mode, a key that identifies such skipped rows is added to the operator's list of rows to be processed at a later time.

摘要翻译： 扩展数据库管理系统以处理SQL语句，以便跳过在冲突模式下锁定的行。 通常，表访问运算符尝试访问锁定在冲突模式（例如写锁定模式）的行时，该行与操作员所需的读取或写入访问不一致。 通常，冲突模式中的锁将由与所讨论的运算符相关联的事务以外的事务来保持。 当正在执行的SQL语句使用本发明提供的“跳过冲突”语法时，操作者跳过锁定在冲突模式的行，否则将导致操作者暂停操作。 此外，如果操作者在流模式下操作，则识别这种跳过的行的密钥将被添加到操作者的稍后将被处理的行的列表中。

公开(公告)号：US08516498B2

公开(公告)日：2013-08-20

申请号：US10698762

申请日：2003-10-31

申请人： Bimal Mehta ,  Paul Maybee ,  Lee Graber ,  Alexander Dadjomov ,  Jean-Emile Elien ,  Eldar Azerovich Musayev ,  Johannes Klein ,  Sanjib Saha ,  Kevin Bowen Smith

发明人： Bimal Mehta ,  Paul Maybee ,  Lee Graber ,  Alexander Dadjomov ,  Jean-Emile Elien ,  Eldar Azerovich Musayev ,  Johannes Klein ,  Sanjib Saha ,  Kevin Bowen Smith

IPC分类号： G06F9/44 ,  G06F11/00

CPC分类号： G06Q10/107 ,  G06Q10/087

摘要： A system and method of processing a message in an asynchronous architecture is provided. In the method, a determination is made that a response to a message sent by an instance of software code is to be received, where the response indicates whether the message succeeded or failed. Another determination is made as to whether the response has been received. If the response has not been received, the instance of the software code is stored in memory, thereby suspending the instance. The response is received, the instance resumed and the response is processed.

摘要翻译： 提供了一种在异步架构中处理消息的系统和方法。 在该方法中，确定将接收对由软件代码的实例发送的消息的响应，其中响应指示消息是成功还是失败。 另外决定是否收到了答复。 如果没有收到响应，则软件代码的实例存储在内存中，从而挂起实例。 收到响应后，实例恢复并响应处理。

公开(公告)号：US20120036075A1

公开(公告)日：2012-02-09

申请号：US12852803

申请日：2010-08-09

申请人： Johannes Klein ,  Ori Bar-Niv ,  David Edward William Mercer ,  Gennady Medvinsky

发明人： Johannes Klein ,  Ori Bar-Niv ,  David Edward William Mercer ,  Gennady Medvinsky

IPC分类号： G06Q30/00 ,  H04L9/32

CPC分类号： G06Q20/16 ,  G06Q20/382 ,  G06Q30/06 ,  G06Q30/0613 ,  H04L9/3234 ,  H04L2209/56 ,  H04L2209/80 ,  H04W12/06

摘要： Identifying a mobile operator account associated with a user to apply charges incurred by the user at a mobile marketplace service. The mobile operator provides an account identifier for the account to a billing token service associated with the mobile marketplace service. The billing token service creates a billing token including the account identifier, and provides the billing token to the user. When subsequently ordering from the mobile marketplace service, the user sends order requests with the billing token to the mobile marketplace service. The mobile marketplace service extracts the account identifier from the billing token and provides the order requests and the extracted account identifier to a mobile operator billing service. The mobile operator billing service applies a charge to the mobile operator account identified by the account identifier. Based on a charge status from the mobile operator billing service (e.g., a successful or unsuccessful charge), the mobile marketplace service allows or denies access by the user to an item identified in the order request.

摘要翻译： 识别与用户相关联的移动运营商帐户，以应用用户在移动市场服务中招致的费用。 移动运营商向帐户提供与移动市场服务相关联的记帐令牌服务的帐户标识符。 记帐令牌服务创建包括帐户标识符的计费令牌，并向用户提供计费令牌。 当随后从移动市场服务订购时，用户将具有记帐令牌的订单请求发送到移动市场服务。 移动市场服务从记帐令牌中提取帐户标识符，并向移动运营商计费服务提供订单请求和提取的帐户标识符。 移动运营商计费服务向由帐户标识符标识的移动运营商帐户应用费用。 基于来自移动运营商记帐服务的收费状态（例如，成功或不成功的收费），移动营销服务允许或拒绝用户对订单请求中识别的项目的访问。

公开(公告)号：US07634583B2

公开(公告)日：2009-12-15

申请号：US10739771

申请日：2003-12-18

申请人： Akash J. Sagar ,  Kevin B. Smith ,  Jean-Emile Elien ,  Johannes Klein

发明人： Akash J. Sagar ,  Kevin B. Smith ,  Jean-Emile Elien ,  Johannes Klein

IPC分类号： G06F15/16

CPC分类号： H04L67/14 ,  H04L69/329

摘要： The present invention relates to systems and methods that facilitate pulling and/or receiving data from a client and posting the data for access by subscribing systems. The systems and methods include a message agent that generates a connection instance that can store connection-related information such as data conveyance state, data identification, and connection identification. Access to the connection instance can be provided to a machine, which can utilize the information to lock the connection and connection instance and begin pulling or receiving data from the client. As the machine pulls or receives data, the data can be published and the connection instance can be concurrently updated to reflect the present state of data conveyance. The information within the connection instance can be utilized to re-establish of severed connection, and to dynamically float the connection between machines to dynamically balance load, ensure reliability and recover from errors.

摘要翻译： 本发明涉及有助于从客户端拉和/或接收数据并且发布用于订阅系统访问的数据的系统和方法。 系统和方法包括消息代理，其生成可以存储诸如数据传送状态，数据标识和连接识别之类的连接相关信息的连接实例。 可以向机器提供对连接实例的访问，该机器可以利用该信息来锁定连接和连接实例，并开始从客户端拉取或接收数据。 随着机器拉或接收数据，可以发布数据，并且可以同时更新连接实例，以反映数据传输的当前状态。 连接实例中的信息可以用于重新建立断开的连接，并动态地浮动机器之间的连接，以动态平衡负载，确保可靠性并从错误中恢复。

公开(公告)号：US07543003B2

公开(公告)日：2009-06-02

申请号：US11211869

申请日：2005-08-25

申请人： Amit Shukla ,  Chang Luo ,  Hua Yuan ,  James D. Ryseff ,  Johannes Klein ,  Lijiang Fang ,  Nigel R. Ellis ,  Siddhartha Singh ,  Srinivasmurthy P. Acharya

发明人： Amit Shukla ,  Chang Luo ,  Hua Yuan ,  James D. Ryseff ,  Johannes Klein ,  Lijiang Fang ,  Nigel R. Ellis ,  Siddhartha Singh ,  Srinivasmurthy P. Acharya

IPC分类号： G06F17/30

CPC分类号： G06F17/30368 ,  Y10S707/99931 ,  Y10S707/99933 ,  Y10S707/99939 ,  Y10S707/99954

摘要： A framework for data change notification includes a notification queue storing event notifications. Client applications can request event information regarding various data change events. For example, a client application can subscribe, via one or more APIs, to receive event information. The framework allows for session specific event notification mechanisms as well as durable event notification mechanisms that can be preserved across client sessions as well as server restarts. Innovative aspects of this invention include guaranteed delivery of event notifications, APIs to allow applications get summary of past events on the subscribed objects, automatic garbage collection/cleanup of notifications when a client session terminates.

摘要翻译： 数据变更通知的框架包括存储事件通知的通知队列。 客户端应用程序可以请求有关各种数据更改事件的事件信息。 例如，客户端应用程序可以通过一个或多个API订阅接收事件信息。 该框架允许会话特定事件通知机制以及持久的事件通知机制，可以跨客户端会话以及服务器重新启动来保留。 本发明的创新方面包括事件通知的保证交付，允许应用程序获取订阅对象上过去事件的摘要的API，客户端会话终止时自动垃圾收集/通知清除。