import { RxAVObject, ICanSaved } from '../RxLeanCloud'; import { IQueryController } from '../internal/query/controller/IQueryController'; import { IAVEncoder } from '../internal/encoding/IAVEncoder'; import { Observable } from 'rxjs'; import { RxAVRealtime, RxAVApp } from '../RxLeanCloud'; /** * 针对 RxAVObject 的查询构建类 * * @export * @class RxAVQuery */ export declare class RxAVQuery { constructor(objectClass: string | RxAVObject, options?: any); className: string; protected _app: RxAVApp; readonly app: RxAVApp; protected _where: any; protected _include: Array; protected _select: Array; protected _limit: number; protected _skip: number; protected _order: Array; protected _extraOptions: { [key: string]: any; }; protected static readonly _encoder: IAVEncoder; protected static readonly _queryController: IQueryController; config(filter: Array<{ key: string; constraint: string; value: any; }>, limit: number, skip: number, include: string[], select: string[]): RxAVQuery; equalTo(key: string, value: any): RxAVQuery; notEqualTo(key: string, value: any): RxAVQuery; lessThan(key: string, value: any): RxAVQuery; lessThanOrEqualTo(key: string, value: any): RxAVQuery; greaterThan(key: string, value: any): RxAVQuery; greaterThanOrEqualTo(key: string, value: any): RxAVQuery; containedIn(key: string, value: any): RxAVQuery; notContainedIn(key: string, value: any): RxAVQuery; containsAll(key: string, values: Array): RxAVQuery; exists(key: string): RxAVQuery; doesNotExist(key: string): RxAVQuery; contains(key: string, value: string): RxAVQuery; startsWith(key: string, value: string): RxAVQuery; endsWith(key: string, value: string): RxAVQuery; protected quote(s: string): string; relatedTo(parent: RxAVObject, key: string): RxAVQuery; ascending(...keys: Array): RxAVQuery; addAscending(...keys: Array): RxAVQuery; descending(...keys: Array): RxAVQuery; addDescending(...keys: Array): RxAVQuery; skip(n: number): RxAVQuery; limit(n: number): RxAVQuery; include(...keys: Array): RxAVQuery; select(...keys: Array): RxAVQuery; /** * 执行查询 * * @returns {Observable>} * * @memberOf RxAVQuery */ find(): Observable>; /** * * * @static * @param {...Array} queries * @returns {RxAVQuery} * * @memberOf RxAVQuery */ static or(...queries: Array): RxAVQuery; protected _orQuery(queries: Array): RxAVQuery; protected _addCondition(key: string, condition: string, value: any): RxAVQuery; protected _encode(value: any, disallowObjects: boolean, forcePointers: boolean): any; buildParameters(includeClassName?: boolean): { [key: string]: any; }; readonly where: any; readonly selectedKeys: string[]; readonly RxWebSocketController: IRxWebSocketController; protected createSubscription(query: RxAVQuery, sessionToken: string): Observable; private _realtime; readonly realtime: RxAVRealtime; subscribe(): Observable; } import { IRxWebSocketController } from '../internal/websocket/controller/IRxWebSocketController'; export declare class RxAVLiveQuery implements ICanSaved { constructor(options?: any); readonly RxWebSocketController: IRxWebSocketController; static readonly LiveQuerySubscriptionCacheKey: string; private static _currentSubscriptions; static getMemory(options?: any): RxAVLiveQuery; static getState(options?: any): RxAVLiveQuery; static getCurrent(options?: any): Observable; saveCurrent(): Observable; toJSONObjectForSaving(): { [key: string]: any; }; bind(): void; id: string; queryId: string; on: Observable<{ scope: string; object: RxAVObject; }>; query: RxAVQuery; sendAck(ids?: Array): void; }