Posts

MongoDB code for Mapreduce,Aggregation and Index

[student@localhost ~]$ su Password: su: Authentication failure [student@localhost ~]$ su Password: [root@localhost student]# systemctl start mongod [root@localhost student]# ./mongo bash: ./mongo: No such file or directory [root@localhost student]# mongo MongoDB shell version: 2.4.6 connecting to: test > use spp switched to db spp > db.createCollection("fruits"); { "ok" : 1 } > db.fruits.insert({"name":"Apple","cost":200}) > db.fruits.insert({"name":"Apple","cost":200}) > db.fruits.insert({"name":"Apple","cost":300}) > db.fruits.mapReduce(function(){emit(this.name,this.price);}function(key,values){return Array.sum(values)},{out:"MapReduce_F"}).find(); Thu Jan  1 14:51:33.905 SyntaxError: Unexpected token function > db.fruits.mapReduce(function(){emit(this.name,this.cost);}function(key,values){return Array.sum(values)},{out:...

Java MongoDB Connectivity -code snippet for Insert,Update,Search,Delete operations

Insert Save a document (data) into a collection (table) named “user”. DBCollection table = db . getCollection ( "user" ) ; BasicDBObject document = new BasicDBObject ( ) ; document . put ( "name" , "mkyong" ) ; document . put ( "age" , 30 ) ; document . put ( "createdDate" , new Date ( ) ) ; table . insert ( document ) ;      Update Update a document where “name=mkyong”. DBCollection table = db . getCollection ( "user" ) ; BasicDBObject query = new BasicDBObject ( ) ; query . put ( "name" , "mkyong" ) ; BasicDBObject newDocument = new BasicDBObject ( ) ; newDocument . put ( "name" , "mkyong-updated" ) ; BasicDBObject updateObj = new BasicDBObject ( ) ; updateObj . put ( "$set" , newDocument ) ; table . update ( query , updateObj ) ; Search Find document where “name=mkyong”, and display it with DBCursor DBCol...

Java MongoDB connectivity Code

package mongoconn; ////import com.mongodb.client.MongoDatabase; import java.net.UnknownHostException; import java.sql.Date; import com.mongodb.BasicDBObject; import com.mongodb.MongoClient; import com.mongodb.DB; import com.mongodb.DBCollection; //import com.mongodb.MongoCredential;  public class myconn{       public static void main( String args[] ) throws UnknownHostException {              // Creating a Mongo client       MongoClient mongo = new MongoClient("localhost" , 27017 );          System.out.println("Connected to the database successfully");                DB db = mongo.getDB("SP");       DBCollection table = db.getCollection("user");                BasicDBOb...

MongoDB queries for CRUD operation

root@localhost student1]# systemctl start mongod [root@localhost student1]# mongo MongoDB shell version: 2.4.6 connecting to: test > show dbs TE     0.203125GB company      0.203125GB local 0.078125GB tecomp       0.203125GB > use shubhangi switched to db shubhangi > show collections > db.createCollection("information") { "ok" : 1 } > db.information.insert({"rollno":101,"name":"shubhangi","marks":85}); > db.information.insert({"rollno":102,"name":"Itisha","marks":90}); > db.information.insert({"rollno":103,"name":"ram","marks":88}); > db.iformation.find() > db.information.find() { "_id" : ObjectId("59b8ba5dc1991a8ea9ff1dea"), "rollno" : 101, "name" : "shubhangi", "marks" : 85 } { "_id" : ObjectId("59b8bacbc1991a8ea9ff1deb...

Java Mysql Connectivity Code

import java.sql.DriverManager; import java.sql.ResultSet; import com.mysql.jdbc.Connection; import com.mysql.jdbc.PreparedStatement; import com.mysql.jdbc.Statement; public class jdbcConn {     private static Connection connect = null;     private static Statement statement = null;     private PreparedStatement preparedStatement = null;     private static ResultSet resultSet = null;     public static void main(String[] args) throws Exception     { try {         // This will load the MySQL driver, each DB has its own driver         Class.forName("com.mysql.jdbc.Driver");         // Setup the connection with the DB         connect = (Connection) DriverManager.getConnection("jdbc:mysql://localhost/emp?"+"user=root");     ...

Example of Cursor in Mysql

DELIMITER //   CREATE PROCEDURE myone()   BEGIN                 declare myno   int(3);      DECLARE done INT DEFAULT FALSE;                 declare mycursor CURSOR for   select roll_no from fine;          DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;          open mycursor;       Label1 : LOOP                                 fetch mycursor into   myno;                           ...

Integrity Constraints

Integrity Constraints There are  1.  domain integrity 2. entity integrity, 3. referential integrity  4. Enterprise  integrity constraints. Domain Integrity Domain integrity means the definition of a valid set of values for an attribute. You define  - data type,  - lenght or size - is null value allowed - is the value unique or not for an attribute. You may also define the default value, the range (values in between) and/or specific values for the attribute. Some DBMS allow you to define the output format and/or input mask for the attribute. These definitions ensure that a specific attribute will have a right and proper value in the database. Entity Integrity Constraint The entity integrity constraint states that primary keys can't be null. There must be a proper value in the primary key field. This is because the primary key value is used to identify individual rows in a table. If there were null values for primary...