Recommend this page to a friend! |
Download |
Info | Example | Files | Install with Composer | Download | Reputation | Support forum | Blog | Links |
Ratings | Unique User Downloads | Download Rankings | ||||
Not yet rated by the users | Total: 75 | All time: 10,189 This week: 206 |
Version | License | PHP version | Categories | |||
mongodb-php-concurre 1.0.0 | MIT/X Consortium ... | 5 | PHP 5, Databases |
Description | Author | |
This package can queue and execute multiple queries using MongoDB. |
<?php |
Concurrency PHP library for MongoDB
Ev extension http://docs.php.net/manual/en/ev.setup.php
### Install
sudo composer require mongo-concurrency/mongo-concurrency @dev
### Examples
<?php
require_once __DIR__ . "/vendor/autoload.php";
$collection = (new MongoDB\Client)->myDb;
$m = new MongoConcurrency\Mongo($collection);
$textData = [];
$options = [];
$intData = [];
echo "Generating test data ... ";
for ($i=1; $i <= 10000 ; $i++) {
array_push($intData, [$i => $i]);
}
for ($i=0; $i <= 5000 ; $i++) {
array_push($textData, ["name" => "john"]);
}
echo "[+] \n";
// select from test1 for 5 seconds with no options array (options is the filter array in : https://docs.mongodb.com/php-library/v1.2/reference/method/MongoDBCollection-findOne/#phpmethod.MongoDB\Collection::findOne) $m->selectFrom("test1", [], 5, function(iterable $results) {
echo " [+] End select : ".sizeof($results)."\n";
});
// insert in to test2 array textData for 1 second $m->insertTo("test2", $textData, 1, function() {
echo " [+] End insert \n";
});
// update from test2 where name = john to name = alex for 6 seconds $m->updateFrom("test2", ["name" => "john"], ["name" => "alex"], 6, function(int $modified) {
echo " [+] End update : ".$modified." \n";
});
// delete from test2 where name = john for 5 seconds $m->deleteFrom("test2", ["name" => "john"], 5, function(int $intDataeleted) {
echo " [+] End delete : ".$intDataeleted."\n";
}); $m->run();
### Results
Files (678) |
File | Role | Description | ||
---|---|---|---|---|
src (1 file) | ||||
vendor (1 file, 2 directories) | ||||
composer.json | Data | Auxiliary data | ||
composer.lock | Data | Auxiliary data | ||
example.php | Example | Example script | ||
LICENSE | Lic. | License text | ||
README.md | Doc. | Documentation |
Files (678) | / | vendor |
File | Role | Description | ||
---|---|---|---|---|
composer (8 files) | ||||
mongodb (1 directory) | ||||
autoload.php | Aux. | Auxiliary script |
Files (678) | / | vendor | / | composer |
File | Role | Description |
---|---|---|
autoload_classmap.php | Aux. | Auxiliary script |
autoload_files.php | Aux. | Auxiliary script |
autoload_namespaces.php | Aux. | Auxiliary script |
autoload_psr4.php | Aux. | Auxiliary script |
autoload_real.php | Class | Class source |
ClassLoader.php | Class | Class source |
installed.json | Data | Auxiliary data |
LICENSE | Lic. | License text |
Files (678) | / | vendor | / | mongodb | / | mongodb |
File | Role | Description | ||
---|---|---|---|---|
.github (1 directory) | ||||
.phpcs (1 file) | ||||
.travis (3 files) | ||||
docs (5 files, 3 directories) | ||||
mongo-orchestration (4 directories) | ||||
src (11 files, 4 directories) | ||||
tests (9 files, 7 directories) | ||||
.travis.yml | Data | Auxiliary data | ||
composer.json | Data | Auxiliary data | ||
CONTRIBUTING.md | Data | Auxiliary data | ||
LICENSE | Lic. | License text | ||
Makefile | Data | Auxiliary data | ||
phpcs.xml.dist | Data | Auxiliary data | ||
phpunit.xml.dist | Data | Auxiliary data | ||
README.md | Doc. | Documentation |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | .github | / | ISSUE_TEMPLATE |
File | Role | Description |
---|---|---|
bug-report.md | Data | Auxiliary data |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | .phpcs |
File | Role | Description |
---|---|---|
autoload.php | Aux. | Auxiliary script |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | .travis |
File | Role | Description |
---|---|---|
debug-core.sh | Data | Auxiliary data |
mo.sh | Data | Auxiliary data |
setup_mo.sh | Data | Auxiliary data |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | docs |
File | Role | Description | ||
---|---|---|---|---|
includes (129 files) | ||||
reference (6 files, 3 directories) | ||||
tutorial (10 files) | ||||
index.txt | Doc. | Documentation | ||
pretty.js | Data | Auxiliary data | ||
reference.txt | Doc. | Documentation | ||
tutorial.txt | Doc. | Documentation | ||
upgrade.txt | Doc. | Documentation |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | docs | / | includes |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | docs | / | reference |
File | Role | Description | ||
---|---|---|---|---|
class (4 files) | ||||
function (1 file) | ||||
method (142 files) | ||||
bson.txt | Doc. | Documentation | ||
enumeration-classes.txt | Doc. | Documentation | ||
exception-classes.txt | Doc. | Documentation | ||
functions.txt | Doc. | Documentation | ||
result-classes.txt | Doc. | Documentation | ||
write-result-classes.txt | Doc. | Documentation |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | docs | / | reference | / | class |
File | Role | Description |
---|---|---|
MongoDBClient.txt | Doc. | Documentation |
MongoDBCollection.txt | Doc. | Documentation |
MongoDBDatabase.txt | Doc. | Documentation |
MongoDBGridFSBucket.txt | Doc. | Documentation |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | docs | / | reference | / | function |
File | Role | Description |
---|---|---|
with_transaction.txt | Doc. | Documentation |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | docs | / | reference | / | method |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | docs | / | tutorial |
File | Role | Description |
---|---|---|
collation.txt | Doc. | Documentation |
commands.txt | Doc. | Documentation |
crud.txt | Doc. | Documentation |
custom-types.txt | Doc. | Documentation |
decimal128.txt | Doc. | Documentation |
example-data.txt | Doc. | Documentation |
gridfs.txt | Doc. | Documentation |
indexes.txt | Doc. | Documentation |
install-php-library.txt | Doc. | Documentation |
tailable-cursor.txt | Doc. | Documentation |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | mongo-orchestration |
File | Role | Description | ||
---|---|---|---|---|
replica_sets (3 files) | ||||
sharded_clusters (2 files) | ||||
ssl (4 files) | ||||
standalone (4 files) |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | mongo-orchestration | / | replica_sets |
File | Role | Description |
---|---|---|
replicaset-old.json | Data | Auxiliary data |
replicaset-one-node.json | Data | Auxiliary data |
replicaset.json | Data | Auxiliary data |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | mongo-orchestration | / | sharded_clusters |
File | Role | Description |
---|---|---|
cluster.json | Data | Auxiliary data |
cluster_replset.json | Data | Auxiliary data |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | mongo-orchestration | / | ssl |
File | Role | Description |
---|---|---|
ca.pem | Data | Auxiliary data |
client.pem | Data | Auxiliary data |
crl.pem | Data | Auxiliary data |
server.pem | Data | Auxiliary data |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | mongo-orchestration | / | standalone |
File | Role | Description |
---|---|---|
standalone-auth.json | Data | Auxiliary data |
standalone-old.json | Data | Auxiliary data |
standalone-ssl.json | Data | Auxiliary data |
standalone.json | Data | Auxiliary data |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | src |
File | Role | Description | ||
---|---|---|---|---|
Exception (7 files) | ||||
GridFS (5 files, 1 directory) | ||||
Model (15 files) | ||||
Operation (37 files) | ||||
BulkWriteResult.php | Class | Class source | ||
ChangeStream.php | Class | Class source | ||
Client.php | Class | Class source | ||
Collection.php | Class | Class source | ||
Database.php | Class | Class source | ||
DeleteResult.php | Class | Class source | ||
functions.php | Example | Example script | ||
InsertManyResult.php | Class | Class source | ||
InsertOneResult.php | Class | Class source | ||
MapReduceResult.php | Class | Class source | ||
UpdateResult.php | Class | Class source |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | src | / | Exception |
File | Role | Description |
---|---|---|
BadMethodCallException.php | Class | Class source |
Exception.php | Class | Class source |
InvalidArgumentException.php | Class | Class source |
ResumeTokenException.php | Class | Class source |
RuntimeException.php | Class | Class source |
UnexpectedValueException.php | Class | Class source |
UnsupportedException.php | Class | Class source |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | src | / | GridFS |
File | Role | Description | ||
---|---|---|---|---|
Exception (2 files) | ||||
Bucket.php | Class | Class source | ||
CollectionWrapper.php | Class | Class source | ||
ReadableStream.php | Class | Class source | ||
StreamWrapper.php | Class | Class source | ||
WritableStream.php | Class | Class source |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | src | / | GridFS | / | Exception |
File | Role | Description |
---|---|---|
CorruptFileException.php | Class | Class source |
FileNotFoundException.php | Class | Class source |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | src | / | Model |
File | Role | Description |
---|---|---|
BSONArray.php | Class | Class source |
BSONDocument.php | Class | Class source |
BSONIterator.php | Class | Class source |
CachingIterator.php | Class | Class source |
ChangeStreamIterator.php | Class | Class source |
CollectionInfo.php | Class | Class source |
CollectionInfoCommandIterator.php | Class | Class source |
CollectionInfoIterator.php | Class | Class source |
DatabaseInfo.php | Class | Class source |
DatabaseInfoIterator.php | Class | Class source |
DatabaseInfoLegacyIterator.php | Class | Class source |
IndexInfo.php | Class | Class source |
IndexInfoIterator.php | Class | Class source |
IndexInfoIteratorIterator.php | Class | Class source |
IndexInput.php | Class | Class source |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | src | / | Operation |
File | Role | Description |
---|---|---|
Aggregate.php | Class | Class source |
BulkWrite.php | Class | Class source |
Count.php | Class | Class source |
CountDocuments.php | Class | Class source |
CreateCollection.php | Class | Class source |
CreateIndexes.php | Class | Class source |
DatabaseCommand.php | Class | Class source |
Delete.php | Class | Class source |
DeleteMany.php | Class | Class source |
DeleteOne.php | Class | Class source |
Distinct.php | Class | Class source |
DropCollection.php | Class | Class source |
DropDatabase.php | Class | Class source |
DropIndexes.php | Class | Class source |
EstimatedDocumentCount.php | Class | Class source |
Executable.php | Class | Class source |
Explain.php | Class | Class source |
Explainable.php | Class | Class source |
Find.php | Class | Class source |
FindAndModify.php | Class | Class source |
FindOne.php | Class | Class source |
FindOneAndDelete.php | Class | Class source |
FindOneAndReplace.php | Class | Class source |
FindOneAndUpdate.php | Class | Class source |
InsertMany.php | Class | Class source |
InsertOne.php | Class | Class source |
ListCollections.php | Class | Class source |
ListDatabases.php | Class | Class source |
ListIndexes.php | Class | Class source |
MapReduce.php | Class | Class source |
ModifyCollection.php | Class | Class source |
ReplaceOne.php | Class | Class source |
Update.php | Class | Class source |
UpdateMany.php | Class | Class source |
UpdateOne.php | Class | Class source |
Watch.php | Class | Class source |
WithTransaction.php | Class | Class source |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests |
File | Role | Description | ||
---|---|---|---|---|
Collection (3 files, 1 directory) | ||||
Compat (1 file) | ||||
Database (3 files) | ||||
GridFS (6 files, 1 directory) | ||||
Model (11 files) | ||||
Operation (58 files) | ||||
SpecTests (15 files, 7 directories) | ||||
bootstrap.php | Class | Class source | ||
ClientFunctionalTest.php | Class | Class source | ||
ClientTest.php | Class | Class source | ||
CommandObserver.php | Class | Class source | ||
DocumentationExamplesTest.php | Class | Class source | ||
FunctionalTestCase.php | Class | Class source | ||
FunctionsTest.php | Class | Class source | ||
PedantryTest.php | Class | Class source | ||
TestCase.php | Class | Class source |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | Collection |
File | Role | Description | ||
---|---|---|---|---|
spec-tests (2 directories) | ||||
CollectionFunctionalTest.php | Class | Class source | ||
CrudSpecFunctionalTest.php | Class | Class source | ||
FunctionalTestCase.php | Class | Class source |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | Collection | / | spec-tests |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | Collection | / | spec-tests | / | read |
File | Role | Description |
---|---|---|
aggregate-collation.json | Data | Auxiliary data |
aggregate-out.json | Data | Auxiliary data |
aggregate.json | Data | Auxiliary data |
count-collation.json | Data | Auxiliary data |
count-empty.json | Data | Auxiliary data |
count.json | Data | Auxiliary data |
distinct-collation.json | Data | Auxiliary data |
distinct.json | Data | Auxiliary data |
find-collation.json | Data | Auxiliary data |
find.json | Data | Auxiliary data |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | Collection | / | spec-tests | / | write |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | Compat |
File | Role | Description |
---|---|---|
PolyfillAssertTrait.php | Class | Class source |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | Database |
File | Role | Description |
---|---|---|
CollectionManagementFunctionalTest.php | Class | Class source |
DatabaseFunctionalTest.php | Class | Class source |
FunctionalTestCase.php | Class | Class source |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | GridFS |
File | Role | Description | ||
---|---|---|---|---|
spec-tests (4 files) | ||||
BucketFunctionalTest.php | Class | Class source | ||
FunctionalTestCase.php | Class | Class source | ||
ReadableStreamFunctionalTest.php | Class | Class source | ||
SpecFunctionalTest.php | Class | Class source | ||
StreamWrapperFunctionalTest.php | Class | Class source | ||
WritableStreamFunctionalTest.php | Class | Class source |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | GridFS | / | spec-tests |
File | Role | Description |
---|---|---|
delete.json | Data | Auxiliary data |
download.json | Data | Auxiliary data |
download_by_name.json | Data | Auxiliary data |
upload.json | Data | Auxiliary data |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | Model |
File | Role | Description |
---|---|---|
BSONArrayTest.php | Class | Class source |
BSONDocumentTest.php | Class | Class source |
BSONIteratorTest.php | Class | Class source |
CachingIteratorTest.php | Class | Class source |
ChangeStreamIteratorTest.php | Class | Class source |
CollectionInfoTest.php | Class | Class source |
DatabaseInfoTest.php | Class | Class source |
IndexInfoFunctionalTest.php | Class | Class source |
IndexInfoTest.php | Class | Class source |
IndexInputTest.php | Class | Class source |
UncloneableObject.php | Class | Class source |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | Operation |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | SpecTests |
File | Role | Description | ||
---|---|---|---|---|
change-streams (5 files) | ||||
command-monitoring (10 files) | ||||
crud (5 files) | ||||
retryable-reads (42 files) | ||||
retryable-writes (20 files) | ||||
transactions-convenient-api (9 files) | ||||
transactions (27 files) | ||||
ChangeStreamsSpecTest.php | Class | Class source | ||
CommandExpectations.php | Class | Class source | ||
CommandMonitoringSpecTest.php | Class | Class source | ||
Context.php | Class | Class source | ||
CrudSpecTest.php | Class | Class source | ||
DocumentsMatchConstraint.php | Class | Class source | ||
DocumentsMatchConstraintTest.php | Class | Class source | ||
ErrorExpectation.php | Class | Class source | ||
FunctionalTestCase.php | Class | Class source | ||
Operation.php | Class | Class source | ||
PrimaryStepDownSpecTest.php | Class | Class source | ||
ResultExpectation.php | Class | Class source | ||
RetryableReadsSpecTest.php | Class | Class source | ||
RetryableWritesSpecTest.php | Class | Class source | ||
TransactionsSpecTest.php | Class | Class source |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | SpecTests | / | change-streams |
File | Role | Description |
---|---|---|
change-streams-errors.json | Data | Auxiliary data |
change-streams-errors.yml | Data | Auxiliary data |
change-streams.json | Data | Auxiliary data |
change-streams.yml | Data | Auxiliary data |
README.rst | Doc. | Documentation |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | SpecTests | / | command-monitoring |
File | Role | Description |
---|---|---|
bulkWrite.json | Data | Auxiliary data |
command.json | Data | Auxiliary data |
deleteMany.json | Data | Auxiliary data |
deleteOne.json | Data | Auxiliary data |
find.json | Data | Auxiliary data |
insertMany.json | Data | Auxiliary data |
insertOne.json | Data | Auxiliary data |
unacknowledgedBulkWrite.json | Data | Auxiliary data |
updateMany.json | Data | Auxiliary data |
updateOne.json | Data | Auxiliary data |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | SpecTests | / | crud |
File | Role | Description |
---|---|---|
aggregate-merge.json | Data | Auxiliary data |
aggregate-out-readConcern.json | Data | Auxiliary data |
bulkWrite-arrayFilters.json | Data | Auxiliary data |
db-aggregate.json | Data | Auxiliary data |
updateWithPipelines.json | Data | Auxiliary data |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | SpecTests | / | retryable-reads |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | SpecTests | / | retryable-writes |
File | Role | Description |
---|---|---|
bulkWrite-serverErrors.json | Data | Auxiliary data |
bulkWrite.json | Data | Auxiliary data |
deleteMany.json | Data | Auxiliary data |
deleteOne-serverErrors.json | Data | Auxiliary data |
deleteOne.json | Data | Auxiliary data |
findOneAndDelete-serverErrors.json | Data | Auxiliary data |
findOneAndDelete.json | Data | Auxiliary data |
findOneAndReplace-serverErrors.json | Data | Auxiliary data |
findOneAndReplace.json | Data | Auxiliary data |
findOneAndUpdate-serverErrors.json | Data | Auxiliary data |
findOneAndUpdate.json | Data | Auxiliary data |
insertMany-serverErrors.json | Data | Auxiliary data |
insertMany.json | Data | Auxiliary data |
insertOne-serverErrors.json | Data | Auxiliary data |
insertOne.json | Data | Auxiliary data |
replaceOne-serverErrors.json | Data | Auxiliary data |
replaceOne.json | Data | Auxiliary data |
updateMany.json | Data | Auxiliary data |
updateOne-serverErrors.json | Data | Auxiliary data |
updateOne.json | Data | Auxiliary data |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | SpecTests | / | transactions-convenient-api |
File | Role | Description |
---|---|---|
callback-aborts.json | Data | Auxiliary data |
callback-commits.json | Data | Auxiliary data |
callback-retry.json | Data | Auxiliary data |
commit-retry.json | Data | Auxiliary data |
commit-transienttr...ctionerror-4.2.json | Data | Auxiliary data |
commit-transienttransactionerror.json | Data | Auxiliary data |
commit-writeconcernerror.json | Data | Auxiliary data |
commit.json | Data | Auxiliary data |
transaction-options.json | Data | Auxiliary data |
Files (678) | / | vendor | / | mongodb | / | mongodb | / | tests | / | SpecTests | / | transactions |
File | Role | Description |
---|---|---|
abort.json | Data | Auxiliary data |
bulk.json | Data | Auxiliary data |
causal-consistency.json | Data | Auxiliary data |
commit.json | Data | Auxiliary data |
count.json | Data | Auxiliary data |
delete.json | Data | Auxiliary data |
error-labels.json | Data | Auxiliary data |
errors-client.json | Data | Auxiliary data |
errors.json | Data | Auxiliary data |
findOneAndDelete.json | Data | Auxiliary data |
findOneAndReplace.json | Data | Auxiliary data |
findOneAndUpdate.json | Data | Auxiliary data |
insert.json | Data | Auxiliary data |
isolation.json | Data | Auxiliary data |
mongos-pin-auto.json | Data | Auxiliary data |
mongos-recovery-token.json | Data | Auxiliary data |
pin-mongos.json | Data | Auxiliary data |
read-concern.json | Data | Auxiliary data |
read-pref.json | Data | Auxiliary data |
reads.json | Data | Auxiliary data |
retryable-abort.json | Data | Auxiliary data |
retryable-commit.json | Data | Auxiliary data |
retryable-writes.json | Data | Auxiliary data |
run-command.json | Data | Auxiliary data |
transaction-options.json | Data | Auxiliary data |
update.json | Data | Auxiliary data |
write-concern.json | Data | Auxiliary data |
The PHP Classes site has supported package installation using the Composer tool since 2013, as you may verify by reading this instructions page. |
Install with Composer |
mongodb-php-concurre-2020-03-03.zip 741KB | |
mongodb-php-concurre-2020-03-03.tar.gz 348KB | |
Install with Composer |
Version Control | Unique User Downloads | Download Rankings | |||||||||||||||
100% |
|
|
Applications that use this package |
If you know an application of this package, send a message to the author to add a link here.