mongodb_mobile 0.0.6 
mongodb_mobile: ^0.0.6 copied to clipboard
A new flutter plugin project.
import 'dart:async';
import 'dart:convert';
import 'dart:math';
import 'package:flutter/cupertino.dart';
import 'package:flutter/material.dart';
import 'package:flutter/services.dart';
import 'package:mongodb_mobile/carrier.dart';
import 'package:mongodb_mobile/mongodb_mobile.dart';
void main() {
debugPrint(
'🍎 🍎 🍎 Flutter MongoDB Mobile Platform Example App starting ... : ${DateTime.now().toIso8601String()} 🧩🧩🧩');
runApp(MyApp());
}
class MyApp extends StatelessWidget {
@override
Widget build(BuildContext context) {
return MaterialApp(
title: 'MongoPluginExample',
debugShowCheckedModeBanner: false,
theme: ThemeData(
primarySwatch: Colors.pink,
),
home: MongoExamplePage(),
);
}
}
class MongoExamplePage extends StatefulWidget {
@override
_MongoExamplePageState createState() => _MongoExamplePageState();
}
class _MongoExamplePageState extends State<MongoExamplePage> {
static const MONGO_CONN =
"mongodb+srv://aubs:aubrey3@ar001-1xhdt.mongodb.net/ardb?retryWrites=true&w=majority";
@override
void initState() {
super.initState();
setMongoAtlasAppID();
listenToMongoChangeEvents();
}
// Platform messages are asynchronous, so we initialize in an async method.
Future<void> setLocalMongoAppID() async {
String platformVersion;
try {
platformVersion = await MongodbMobile.platformVersion;
debugPrint('_MyAppState: 🧩🧩🧩 Platform Version : 🍎 $platformVersion');
var res = await MongodbMobile.setAppID({
'appID': 'exampleApp',
'type': MongodbMobile.LOCAL_DATABASE,
});
print(res);
showSnackbar(
scaffoldKey: _key,
message: '🏀 🏀 🏀 LOCAL DB connection succeeded',
textColor: Colors.white,
backgroundColor: Colors.teal.shade900);
} on PlatformException catch (f) {
print('👿👿👿👿👿👿👿👿 PlatformException 🍎 🍎 🍎 - $f');
showSnackbar(
scaffoldKey: _key,
message: '👽 Local database connection failed 👽 👽 👽 ',
textColor: Colors.yellow,
backgroundColor: Colors.pink.shade900);
}
if (!mounted) return;
setState(() {});
}
static const API_KEY =
"HkcniZshpeSsJFgHxFYvBbGppUZyOEDFyrVwzsjqSXzluBy16r90EBTU5esygnuW";
Future<void> setMongoAtlasAppID() async {
try {
debugPrint('\n\n 🍎 🍎 🍎 setting remote MongoDB Stitch App ID ....');
var res = await MongodbMobile.setAppID({
'appID': 'routebuilder-scewg',
'type': MongodbMobile.ATLAS_DATABASE,
'email': 'hacker1@admin',
'password': 'aubrey3'
});
print(res);
showSnackbar(
scaffoldKey: _key,
message: '❤️ 🧡 💛 💚 💙 💜 Mongo Atlas connected',
textColor: Colors.white,
backgroundColor: Colors.teal.shade900);
} on PlatformException catch (f) {
print('👿👿👿👿👿👿👿👿 PlatformException 🍎 🍎 🍎 - $f');
showSnackbar(
scaffoldKey: _key,
message: '👽 Atlas connection failed 👽 👽 👽 ',
textColor: Colors.yellow,
backgroundColor: Colors.pink.shade900);
}
if (!mounted) return;
setState(() {});
}
Random random = Random(DateTime.now().millisecondsSinceEpoch);
String db = 'ardb', collection = "testCollection";
/// Add document to a collection
Future insertDocument() async {
debugPrint('\n\n💙 💙 inserting a document ....');
dynamic result;
try {
var fIndex = random.nextInt(fNames.length - 1);
var lIndex = random.nextInt(lNames.length - 1);
var carrier = Carrier(db: db, collection: collection, data: {
'name': fNames.elementAt(fIndex),
'lastName': lNames.elementAt(lIndex),
'wealth': random.nextInt(100000) * 1.04,
'date': DateTime.now().toUtc().toIso8601String(),
'desc': '🍎 serve with purpose 💙'
});
result = await MongodbMobile.insert(carrier);
debugPrint(
'\n\n🧩🧩🧩🧩🧩🧩 _MyAppState: insertDocument 🧩🧩🧩 document added : 🍎 id: $result\n\n\n');
showSnackbar(
message: ' 🧩🧩🧩 Document inserted',
scaffoldKey: _key,
backgroundColor: Colors.black,
textColor: Colors.white);
} on PlatformException catch (f) {
print('👿👿👿👿👿👿👿👿 PlatformException 🍎 🍎 🍎 - $f');
showSnackbar(
message: ' 😡 😡 Document insert failed',
scaffoldKey: _key,
backgroundColor: Colors.red.shade700,
textColor: Colors.yellow);
}
}
/// Sync collection
Future syncCollection() async {
debugPrint('\n\n💙 💙 syncCollection ....');
dynamic result;
try {
var carrier = Carrier(db: db, collection: collection);
result = await MongodbMobile.sync(carrier);
debugPrint(
'\n\n🧩🧩🧩🧩🧩🧩 _MyAppState: syncCollection: 🧩🧩🧩 🍎 result: $result\n\n\n');
showSnackbar(
message: ' 🧩🧩🧩 Mobile - Atlas Sync started',
scaffoldKey: _key,
backgroundColor: Colors.black,
textColor: Colors.white);
} on PlatformException catch (f) {
print('👿👿👿👿👿👿👿👿 PlatformException 🍎 🍎 🍎 - $f');
showSnackbar(
message: ' 😡 😡 Sync Collection failed',
scaffoldKey: _key,
backgroundColor: Colors.red.shade700,
textColor: Colors.yellowAccent);
}
}
/// Add document to a collection
Future addToArray() async {
debugPrint('\n\n💙 💙 addToArray nested in document ....');
dynamic result;
try {
var carrier = Carrier(
db: db,
collection: collection,
id: "5cfc15746bc8314e89118348",
arrayName: "musicTracks",
arrayKey: new DateTime.now().millisecondsSinceEpoch.toString(),
data: {
'artist': 'Michael Jackson',
'track': 'Dirty Diana',
'date': new DateTime.now().toIso8601String(),
});
result = await MongodbMobile.addToArray(carrier);
debugPrint(
'\n\n🧩🧩🧩🧩🧩🧩 _MyAppState: addToArray 🧩🧩🧩 element added to nested array : 🍎 result: $result\n\n\n');
showSnackbar(
message: ' 🧩🧩🧩 element added to nested array',
scaffoldKey: _key,
backgroundColor: Colors.black,
textColor: Colors.lightBlue);
} on PlatformException catch (f) {
print('👿👿👿👿👿👿👿👿 PlatformException 🍎 🍎 🍎 - $f');
showSnackbar(
scaffoldKey: _key,
message: f.message,
textColor: Colors.yellow,
backgroundColor: Colors.red);
}
}
List documents = List();
/// Get all documents from a collection
Future getAllDocuments() async {
debugPrint('\n\n💙 💙 getAllDocuments ....');
try {
var carrier = Carrier(db: db, collection: collection);
documents = await MongodbMobile.getAll(carrier);
debugPrint(
'\n\n🍎 🍎 🍎 _MyAppState: getAllDocuments 🧩🧩🧩 retrieved : 🍎 ${documents.length} documents 🍎 \n\n\n');
var cnt = 0;
documents.forEach((m) {
cnt++;
debugPrint(' 🧩🧩🧩 #$cnt 👌 $m');
});
showSnackbar(
message: '🍎 🍎 🍎 ${documents.length} documents found',
scaffoldKey: _key,
backgroundColor: Colors.black,
textColor: Colors.white);
} on PlatformException catch (f) {
print('👿👿👿👿👿👿👿👿 PlatformException 🍎 🍎 🍎 - $f');
}
}
/// Delete document from a collection
Future delete() async {
debugPrint('\n\n💙 💙 delete ....');
try {
var carrier = Carrier(
db: db, collection: collection, id: '5cfbe8b96bc8317dab43d14e');
var res = await MongodbMobile.delete(carrier);
debugPrint(
'\n\n🍎 🍎 🍎 _MyAppState:delete: 🧩🧩🧩 deleted : 🍎 : $res 🍎 \n\n\n');
showSnackbar(
message: '🍎 🍎 🍎 document deleted',
scaffoldKey: _key,
backgroundColor: Colors.black,
textColor: Colors.white);
} on PlatformException catch (f) {
print('👿👿👿👿👿👿👿👿 PlatformException 🍎 🍎 🍎 - $f');
}
}
/// get one document from a collection
Future getOne() async {
debugPrint('\n\n💙 💙 get one doc ....');
try {
var carrier = Carrier(
db: db, collection: collection, id: '5cfbe8ba6bc8317dab43d152');
var res = await MongodbMobile.getOne(carrier);
debugPrint(
'\n\n🍎 🍎 🍎 _MyAppState:getOne: 🧩🧩🧩 get one : 🍎 : $res 🍎 \n\n\n');
showSnackbar(
message: '🍎 🍎 🍎 document retrieved',
scaffoldKey: _key,
backgroundColor: Colors.black,
textColor: Colors.white);
} on PlatformException catch (f) {
print('👿👿👿👿👿👿👿👿 PlatformException 🍎 🍎 🍎 - $f');
}
}
/// Replace document from a collection
Future updateDocument() async {
debugPrint('\n\n💙 💙 replace ....');
try {
var carrier = Carrier(
db: db,
collection: collection,
id: '5cfbe8ba6bc8317dab43d151',
fields: {
'name': 'Aubrey 👽 St. Vincent',
'lastName': 'Malabie 🦊🦊🦊 III',
'wealth': 777007.77,
'date': DateTime.now().toUtc().toIso8601String(),
'desc': '🐬 🍎 serve with UPDATED purpose 🍎 🐬 '
});
var res = await MongodbMobile.update(carrier);
debugPrint(
'\n\n🍎 🍎 🍎 _MyAppState:replace: 🧩🧩🧩 replaced : 🍎 1 document : $res 🍎 \n\n\n');
showSnackbar(
message: '🍎 🍎 🍎 document replaced',
scaffoldKey: _key,
backgroundColor: Colors.indigo.shade800,
textColor: Colors.white);
} on PlatformException catch (f) {
print('👿👿👿👿👿👿👿👿 PlatformException 🍎 🍎 🍎 - $f');
}
}
/// Query Mongo database using collection properties
Future query() async {
debugPrint('\n\n💙 💙 getByProperty ....');
try {
var carrier = Carrier(db: db, collection: collection, query: {
"gt": {"wealth": 5000},
"eq": {"lastName": lNames.elementAt(random.nextInt(lNames.length - 1))},
"and": true,
"or": false,
"limit": 0
});
dynamic object = await MongodbMobile.query(carrier);
debugPrint(
'\n\n🍎 🍎 🍎 _MyAppState: query: 🧩🧩🧩 retrieved : 🍎 ${object.length} documents 🍎 see below: \n\n\n');
var cnt = 0;
object.forEach((m) {
cnt++;
debugPrint(' 🥬🥬🥬 #$cnt 👌 $m');
});
showSnackbar(
message: ' 🍎 🍎 🍎 ${object.length} documents found',
scaffoldKey: _key,
backgroundColor: Colors.purple,
textColor: Colors.white);
} on PlatformException catch (f) {
print('👿👿👿👿👿👿👿👿 PlatformException 🍎 🍎 🍎 - $f');
}
}
EventChannel channel = EventChannel(MongodbMobile.MONGO_CHANGE_EVENTS);
void listenToMongoChangeEvents() {
// Consuming events on the Dart side.
channel.receiveBroadcastStream().listen((dynamic event) {
print(
'\n\n🌺 🌺 🌺 Received change event from Mongo: 🦠 $event 🦠 🦠 🦠 \n\n');
var changeEvent = json.decode(event['changeEvent']);
var document = json.decode(event['document']);
print(changeEvent);
print(document);
}, onError: (dynamic error) {
print('Received error: ${error.message}');
});
print(
'\n\n🦠 🦠 🦠 Listening to Channel events for 🦠 Mongo Change Events\n');
}
void showSnackbar(
{@required GlobalKey<ScaffoldState> scaffoldKey,
@required String message,
@required Color textColor,
@required Color backgroundColor}) {
if (scaffoldKey.currentState == null) {
print('AppSnackbar.showSnackbar --- currentState is NULL, quit ..');
return;
}
scaffoldKey.currentState.removeCurrentSnackBar();
scaffoldKey.currentState.showSnackBar(new SnackBar(
content: _getText(message, textColor),
duration: new Duration(seconds: 15),
backgroundColor: backgroundColor,
));
}
static Widget _getText(
String message,
Color textColor,
) {
return Text(
message,
overflow: TextOverflow.clip,
style: new TextStyle(color: textColor),
);
}
GlobalKey<ScaffoldState> _key = GlobalKey();
bool isRemote = true;
BuildContext mContext;
TextEditingController _appIDController = TextEditingController();
TextEditingController _dbController = TextEditingController();
TextEditingController _collectionController = TextEditingController();
void _onSwitchChanged(bool status) {
debugPrint('onSwitchChanged: 🚼 🚼 $status');
setState(() {
isRemote = status;
});
if (isRemote) {
setMongoAtlasAppID();
} else {
setLocalMongoAppID();
}
}
void _onConfigSwitchChanged(bool status) {
debugPrint('_onConfigSwitchChanged: 🚼 🚼 $status');
Navigator.pop(context);
setState(() {
isRemote = status;
});
_openConfig();
}
setSelectedRadio(int val) {
setState(() {
selectedRadio = val;
});
}
String appID, collectionName, databaseName;
_onAppIDChanged(String value) {
print(value);
appID = value;
}
_onDBChanged(String value) {
print(value);
databaseName = value;
}
_onCollectionChanged(String value) {
print(value);
collectionName = value;
}
int selectedRadio;
@override
Widget build(BuildContext context) {
return Scaffold(
key: _key,
appBar: AppBar(
title: Center(
child: Padding(
padding: EdgeInsets.all(12),
child: Text(
'MongoDB Plugin',
style: TextStyle(
fontWeight: FontWeight.w900,
fontSize: 20,
color: Colors.white),
),
),
),
actions: <Widget>[
IconButton(
icon: Icon(Icons.settings),
onPressed: _openConfig,
),
],
backgroundColor:
isRemote ? Colors.pink.shade300 : Colors.deepOrange.shade300,
bottom: PreferredSize(
preferredSize: Size.fromHeight(80),
child: Padding(
padding: const EdgeInsets.all(16.0),
child: Column(
children: <Widget>[
SizedBox(
height: 8,
),
Row(
children: <Widget>[
Text(
'MODE',
style: TextStyle(color: Colors.white),
),
SizedBox(
width: 12,
),
Switch(
onChanged: _onSwitchChanged,
activeColor: Colors.blue.shade800,
value: isRemote,
),
SizedBox(
width: 12,
),
Text(
isRemote ? 'MongoDB Atlas' : 'Local Database',
style: TextStyle(
fontSize: 24,
color: Colors.white,
fontWeight: FontWeight.w900),
),
],
),
],
),
),
),
),
backgroundColor: Colors.brown.shade50,
floatingActionButton: FloatingActionButton(
onPressed: () {
_showInfo();
},
child: Icon(Icons.bug_report),
backgroundColor:
isRemote ? Colors.pink.shade600 : Colors.deepOrange.shade600,
elevation: 24,
),
body: Center(
child: Padding(
padding: const EdgeInsets.all(12.0),
child: Card(
elevation: 8,
child: Padding(
padding: const EdgeInsets.all(20.0),
child: ListView(
children: <Widget>[
Center(
child: Text(
'8 Mongo API\'s',
style: TextStyle(
fontSize: 16,
fontWeight: FontWeight.w900,
color: Colors.indigo.shade200),
),
),
SizedBox(
height: 8,
),
Container(
width: 260,
child: RaisedButton(
onPressed: insertDocument,
elevation: 16,
color: Colors.pink.shade300,
child: Padding(
padding: const EdgeInsets.all(20.0),
child: Text(
'Insert One Document',
style: TextStyle(color: Colors.white),
),
),
),
),
SizedBox(
height: 12,
),
Container(
width: 260,
child: RaisedButton(
onPressed: getAllDocuments,
elevation: 16,
color: Colors.purple.shade300,
child: Padding(
padding: const EdgeInsets.all(20.0),
child: Text(
'Get All Documents',
style: TextStyle(color: Colors.white),
),
),
),
),
SizedBox(
height: 12,
),
Container(
width: 260,
child: RaisedButton(
onPressed: query,
elevation: 16,
color: Colors.teal.shade300,
child: Padding(
padding: const EdgeInsets.all(20.0),
child: Text(
'Query By Properties',
style: TextStyle(color: Colors.white),
),
),
),
),
SizedBox(
height: 12,
),
Container(
width: 260,
child: RaisedButton(
onPressed: delete,
elevation: 16,
color: Colors.blue.shade400,
child: Padding(
padding: const EdgeInsets.all(20.0),
child: Text(
'Delete Document',
style: TextStyle(color: Colors.white),
),
),
),
),
SizedBox(
height: 12,
),
Container(
width: 260,
child: RaisedButton(
onPressed: updateDocument,
elevation: 16,
color: Colors.brown.shade400,
child: Padding(
padding: const EdgeInsets.all(20.0),
child: Text(
'Update Document',
style: TextStyle(color: Colors.white),
),
),
),
),
SizedBox(
height: 12,
),
Container(
width: 260,
child: RaisedButton(
onPressed: getOne,
elevation: 16,
color: Colors.indigo.shade400,
child: Padding(
padding: const EdgeInsets.all(20.0),
child: Text(
'Get One Document',
style: TextStyle(color: Colors.white),
),
),
),
),
SizedBox(
height: 12,
),
Container(
width: 260,
child: RaisedButton(
onPressed: addToArray,
elevation: 16,
color: Colors.orange.shade500,
child: Padding(
padding: const EdgeInsets.all(20.0),
child: Text(
'Add To Nested Array',
style: TextStyle(color: Colors.white),
),
),
),
),
SizedBox(
height: 12,
),
isRemote
? Container(
width: 260,
child: RaisedButton(
onPressed: syncCollection,
elevation: 16,
color: Colors.lime.shade700,
child: Padding(
padding: const EdgeInsets.all(20.0),
child: Text(
'Sync Collection',
style: TextStyle(color: Colors.white),
),
),
),
)
: Container(),
SizedBox(
height: 12,
),
Text(txt),
],
),
),
),
),
),
);
}
void _openConfig() {
showDialog<void>(
context: context,
barrierDismissible:
false, // false = user must tap button, true = tap outside dialog
builder: (BuildContext dialogContext) {
return AlertDialog(
title: Text(
'DB Configuration',
style: TextStyle(fontWeight: FontWeight.w900, fontSize: 20),
),
content: Container(
height: 300,
width: 400,
child: Column(
children: <Widget>[
Row(
crossAxisAlignment: CrossAxisAlignment.center,
children: <Widget>[
Text('Atlas'),
SizedBox(
width: 4,
),
Radio(
value: 1,
materialTapTargetSize: MaterialTapTargetSize.padded,
activeColor: Colors.green,
onChanged: (val) {
print("Atlas Selected: 🍒 🍒 🍒 $val");
setSelectedRadio(val);
},
),
SizedBox(width: 20,),
Text('Mobile'),
SizedBox(
width: 4,
),
Radio(
value: 2,
activeColor: Colors.blue,
materialTapTargetSize: MaterialTapTargetSize.padded,
onChanged: (val) {
print("Local Database selected: 🥝 🥝 🥝 $val");
setSelectedRadio(val);
},
),
SizedBox(
width: 4,
),
],
),
Row(
children: <Widget>[
Text(
isRemote ? 'Mongo Atlas Database' : 'Local Database',
style: TextStyle(fontSize: 20, fontWeight: FontWeight.w900),
textAlign: TextAlign.left,
),
],
),
SizedBox(
height: 24,
),
TextField(
controller: _appIDController,
onChanged: _onAppIDChanged,
keyboardType: TextInputType.text,
decoration: InputDecoration(hintText: 'Enter Stitch AppID'),
),
SizedBox(
height: 12,
),
TextField(
controller: _dbController,
onChanged: _onDBChanged,
keyboardType: TextInputType.text,
decoration: InputDecoration(hintText: 'Enter Database Name'),
),
SizedBox(
height: 12,
),
TextField(
controller: _collectionController,
onChanged: _onCollectionChanged,
keyboardType: TextInputType.text,
decoration:
InputDecoration(hintText: 'Enter Collection Name'),
),
],
),
),
actions: <Widget>[
FlatButton(
child: Text('Cancel'),
onPressed: () {
Navigator.of(dialogContext).pop(); // Dismiss alert dialog
},
),
RaisedButton(
onPressed: _activateConfig,
elevation: 8,
color: Colors.indigo,
child: Padding(
padding: EdgeInsets.all(16),
child: Text(
'Start Config',
style: TextStyle(color: Colors.white),
),
),
),
],
);
},
);
}
_activateConfig() {
print('🍎 🍎 🍎 🍎 🍎 🍎 activateConfig ...............');
}
var txt = '💚 💙 💜 Flutter MongoDB Mobile Plugin ' +
'This project contains the source code for a plugin that enables Flutter apps to use the MongoDB Mobile embedded database. '
'The example app included creates a database and a test collection and helps to load data.';
var txt2 = 'For more, check out the source code in Github!';
void _showInfo() {
showDialog(
context: context,
builder: (_) => new AlertDialog(
title: new Text(
"MongoDB Plugin",
style: TextStyle(
fontWeight: FontWeight.w900,
fontSize: 28,
color: Theme.of(context).primaryColor),
),
content: Container(
height: 260.0,
child: Column(
children: <Widget>[
Padding(
padding: const EdgeInsets.all(20.0),
child: Column(
children: <Widget>[
Text(
info,
style: TextStyle(
fontWeight: FontWeight.normal, fontSize: 16),
),
SizedBox(
height: 20,
),
Text(
txt2,
style: TextStyle(
fontWeight: FontWeight.normal, fontSize: 16),
),
SizedBox(
height: 12,
),
],
),
),
],
),
),
actions: <Widget>[
Padding(
padding: const EdgeInsets.only(bottom: 20.0),
child: FlatButton(
onPressed: () {
Navigator.pop(context);
},
// color: Colors.blue.shade700,
child: Padding(
padding: const EdgeInsets.all(16.0),
child: Text(
'CLOSE, Thanks!',
style: TextStyle(color: Colors.blue.shade600),
),
),
),
),
],
));
}
var info =
'🍎 This app exercises all the API\'s from the Flutter mongodb_mobile plugin in the Dart Pub library 🍎 🍎 🍎';
List<String> fNames = [
"John",
"Vusi",
"Lulu",
"Kgabi",
"Peter",
"Cyril",
"Nancy",
"Donald",
'Rogers',
'Lesego',
'Leslie',
'Fatima',
"Catherine",
'Musapa',
'Benjamin',
'Rachel',
'Georgia',
'California',
"Obby",
"Tiger"
];
List<String> lNames = [
"Marule",
"Woods",
"Obama",
'Trump',
'van der Merwe',
'Sithole',
"Ramaphosa",
"Malenga",
"Jackson",
"Maringa",
"Johnson",
"Petersen",
"Bhengu"
];
}Metadata
1
likes
20
pub points
0%
popularity
Publisher
unverified uploader
Metadata
A new flutter plugin project.
Repository (GitHub)
View/report issues
License
unknown (LICENSE)
