Статьи

MongoDB и веб-приложения

Январь 28, 2019

Сегодняшняя эпоха — это когда данные растут в очень больших масштабах. Хранение данных не является проблемой, но структура и хранение данных могут увеличить или уменьшить время поиска необходимых блоков данных.

Использование случаев постоянно увеличивающихся неструктурированных данных

  • facebook:
    • Активно 750 миллионов пользователей, каждый третий интернет-пользователь имеет аккаунт в Facebook
    • Более 30 миллиардов единиц контента (веб-ссылки, новости, записи в блогах, заметки, фотоальбомы и т. Д.) Делятся каждый месяц.
    • Содержит 30PB данных для анализа, добавляет 12 ТБ сжатых данных ежедневно
  • щебет
    • 200 миллионов пользователей, 200 миллионов ежедневных твитов
    • 1,6 миллиарда поисковых запросов в день
    • 7 данных ТБ для анализа генерируются ежедневно

В этих масштабах традиционное хранение данных, методы и инструменты анализа не работают!

Современные сценарии требуют использования баз данных NoSQL, таких как Apache Cassandra, Mongo DB, для работы с такими постоянно увеличивающимися неструктурированными данными. База данных NoSQL обеспечивает более слабые модели согласованности, чем традиционные СУБД, для хранения и поиска данных. Базы данных NoSQL хранят данные в виде высокооптимизированных пар ключ-значение, что приводит к простым операциям поиска и добавления, что повышает производительность с точки зрения низкой задержки и высокой пропускной способности.

Базы данных NoSQL играют важную роль в отраслях, где разрабатываются и поддерживаются большие данные и веб- приложения в реальном времени .

Вариант использования для БД Mongo и веб-приложений

Давайте представим, что мы хотим создать портал регистрации автомобилей, используя JSF2.0 и Mongo DB на своем бэкэнде. Там будет две функциональности

  • Регистрация автомобиля
  • Для просмотра отчета о зарегистрированных автомобилях

На рисунке 1 изображен поток проекта, который предполагается сделать.

Предположения:

  • Mongo DB уже установлена ​​и работает как сервис
  • Затмение Индиго или выше версия
  • Tomcat 7.0 или более поздняя версия
  • Необходимые jar-файлы присутствуют (JSF2.0 jars jsf-api.jar, jsf-impl), mongo-java-driver-2.10.1.jar или любая подходящая версия

Приложение имеет три страницы, а именно: Home.xhtml, AddCar.xhtml, Report.xhtml.

Реализация Home.xhtml выглядит следующим образом:

Home.xhtml

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml"
    xmlns:f="http://java.sun.com/jsf/core"
    xmlns:h="http://java.sun.com/jsf/html"
    xmlns:j="http://java.sun.com/jsp/jstl/core">
<h:head>
 
<meta http-equiv="content-type" content="text/html; charset=utf-8" />
 
</h:head>
 
<h:body>
 
<f:view>
<h:form>
 
<center>
<h2> MSD Car Portal</h2>
     
 
<h4>
 
<h:outputLink value="AddCar.xhtml">Add Car</h:outputLink><br/><br/>
<h:commandLink action="#{carBean.getCarDetails}" >See Registered Cars</h:commandLink>
 
</h4>
 
</center>
 
</h:form>
</f:view>
 
</h:body>
</html>

При нажатии на ссылку « Добавить автомобиль» загружается файл AddCar.xhtml и выполняются следующие строки кода.

AddCar.xhtml

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml"
    xmlns:f="http://java.sun.com/jsf/core"
    xmlns:h="http://java.sun.com/jsf/html"
    xmlns:j="http://java.sun.com/jsp/jstl/core">
<h:head>
 
<meta http-equiv="content-type" content="text/html; charset=utf-8" />
 
</h:head>
 
<h:body>
 
<f:view>
<h:form>
 
<center>
 
<h2>MSD Car Portal</h2>
<h3>Add a Car</h3>
 
 
 
<h:panelGrid border="2" columns="2">
 
<h:outputText value="CarName"></h:outputText>
<h:inputText value="#{carBean.carTO.carName}"></h:inputText>
 
<h:outputText value="Company"></h:outputText>
<h:inputText value="#{carBean.carTO.company}"></h:inputText>
 
<h:outputText value="Model"></h:outputText>
<h:inputText value="#{carBean.carTO.model}">
<f:convertDateTime pattern="dd-MMM-yyyy"></f:convertDateTime>
</h:inputText>
 
<h:outputText value="CC"></h:outputText>
<h:inputText value="#{carBean.carTO.cc}"></h:inputText>
 
<h:outputText value="Price"></h:outputText>
<h:inputText value="#{carBean.carTO.price}"></h:inputText>
 
</h:panelGrid>
 
 
<h:commandButton action="#{carBean.addCar}" value="Add Car"></h:commandButton><br/>
                 
<h:outputText value="#{carBean.message}"></h:outputText>
                 
<br/><h:outputLink value="Home.xhtml">Home</h:outputLink>
             
</center>
 
</h:form>
</f:view>
 
</h:body>
</html>

При нажатии кнопки « Добавить автомобиль» вызывается обработчик действия CarBean ( базового компонента), и в базовом компоненте CarTO (объект передачи автомобиля) отправляется функции insertData CarService , здесь путем вставки значений значений CarTO в документ и добавление документа в коллекцию. И при нажатии Home Home.xhtml показывается. Следующий листинг показывает код для CarBean .

CarBean.java

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
package mongo.db.bean;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.List;
import javax.faces.bean.ManagedBean;
import mongo.db.service.CarService;
import mongo.db.to.CarTO;
@ManagedBean
public class CarBean {
    private List<CarTO> list = new ArrayList<CarTO>();
    private String message;
    private CarTO carTO= new CarTO();
 
      /**Action handler to save the data in the collection*/
    public String addCar(){
    try {
       /**Inserting the data to the Service class to insert it into
         Mongo DB*/
      message= new CarService()
              .insertData("testdb","MyNewJAVATableCollection3",carTO);
        /**Message property is shown on the Page to show success
          message on the page*/
    } catch (UnknownHostException e) {
      message= e.getMessage();
    }
      return "samePage";
    }
    /**Action handler to get the data from the collection*/
    public String getCarDetails(){
    try {
        /**Reading the data From the Service class which further read
          the data from the  Mongo DB */
      list = new CarService()
              .findData("testdb","MyNewJAVATableCollection3");
              
                if(list.size()==0){
                message="No records Exist";
            }
        } catch (UnknownHostException e) {
        message= e.getMessage();
        }
        return "success";
    }
/*Getters  and setters to be coded*/
}

Код для класса обслуживания выглядит следующим образом:

CarService.java

001
002
003
004
005
006
007
008
009
010
011
012
013
014
015
016
017
018
019
020
021
022
023
024
025
026
027
028
029
030
031
032
033
034
035
036
037
038
039
040
041
042
043
044
045
046
047
048
049
050
051
052
053
054
055
056
057
058
059
060
061
062
063
064
065
066
067
068
069
070
071
072
073
074
075
076
077
078
079
080
081
082
083
084
085
086
087
088
089
090
091
092
093
094
095
096
097
098
099
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
package mongo.db.service;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
import mongo.db.to.CarTO;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;
 
public class CarService {
 
/**Utility to Get the Connection from the database*/
public static DBCollection getConnection(String dbName, String collectionName)throws UnknownHostException {
         
           /** Connecting to MongoDB */
        MongoClient mongo = new MongoClient("localhost", 27017);
 
        /**Gets database, incase if the database is not existing
             MongoDB Creates it for you*/
        DB db = mongo.getDB(dbName);
 
        /**Gets collection / table from database specified if
             collection doesn't exists, MongoDB will create it for
             you*/
        DBCollection table = db.getCollection(collectionName);
        return table;
    }
 
 
 
 
 
 
     
/**function to insert the data to the database */
public  String insertData(String dbName, String collectionName, CarTO carTO) throws UnknownHostException {
 
/**Connecting to MongoDB*/
DBCollection table =CarService.getConnection(dbName, collectionName);
     
 
/**creating a document to store as key and value*/
        BasicDBObject document = new BasicDBObject();
        document.put("carName", carTO.getCarName());
        document.put("company", carTO.getCompany());
        document.put("model", carTO.getModel());
        document.put("cc", carTO.getCc());
        document.put("Price", carTO.getPrice());
         
/** inserting to the document to collection or table*/
        table.insert(document);
        return "Car added successfully with the record number :"+table.count();
}
 
 
/**function to get Details from the database*/
public  List<CarTO> findData(String dbName, String collectionName) throws UnknownHostException {
 
/**Connecting to database*/
DBCollection table= CarService.getConnection(dbName, collectionName);
         
/**getting results from the database*/
DBCursor cursor = table.find();
List<CarTO>list= new ArrayList<CarTO>();
 
/**iterating over the documents got from the database*/
while (cursor.hasNext()) {
             
DBObject obj= cursor.next();
 
/**documentToMapUtility is coded to convert the document received from database to key value pairs and put it inside a map*/
Map map=CarService.documentToMapUtility(obj.toString());
 
 
 
 
 
/**Map having values is iterated using entry set and CarTO is populated and CarTO is added in the List<CarTO> and this list returned*/
 
/**Getting the Entery Set from the map  */
Set<Entry<String,String>> set=  map.entrySet();
 
/**Getting the Iterator to iterate the entry Set*/
Iterator<Entry<String,String>> itr= set.iterator();
            CarTO carTO = new CarTO();
 
/**loop to put ever Key value pair to CarTO object*/         
  while(itr.hasNext()){
     
            Entry<String, String> entry = itr.next();
            String key=entry.getKey();
 
          /**Removing the unwanted from the keys*/
            key = CarService.subStringUtility(key);
             
           String value=entry.getValue();
                 
        if(key.equalsIgnoreCase("carName")){
            carTO.setCarName(value.substring(2,value.length()-2));
        }else if(key.equalsIgnoreCase("company")){
        carTO.setCompany(value.substring(2,value.length()-2));
        }else if(key.equalsIgnoreCase("model")){
         String date[]=value.split("-");
         int year=Integer.parseInt(date[0].substring(2));
         int month=Integer.parseInt(date[1]);
         int datemon=Integer.parseInt(date[2].substring(0, date.length-1));
          
        Calendar c= Calendar.getInstance();
            c.set(Calendar.YEAR, year);
            c.set(Calendar.MONTH, month);
            c.set(Calendar.DATE, datemon);
            carTO.setModel(c.getTime());
            }else if(key.equalsIgnoreCase("cc")){
            carTO.setCc(Integer.parseInt(value.trim()));
            }else if(key.equalsIgnoreCase("Price")){
            carTO.setPrice(Double.parseDouble(value.trim()));
            }
    }          /**inner While closed*/
   list.add(carTO);
}   /**while iterating over the cursor records closed here*/
        return list;
}
 
    /**Utility to remove un wanted contents*/
    public static String subStringUtility (String s){
         
        return s.substring(2,s.length()-2);
    }
     
 
      /**Utility to convert the document to map*/
    public static Map<String,String> documentToMapUtility (String s){
        s= s.substring(1,s.length()-1);
        String sArr[]= s.split(",");
        Map<String,String> map = new LinkedHashMap<String,String>();
        for(int i=1;i<sArr.length;i++){
            if(!sArr[i].contains("$date")){
            String keyValue[]= sArr[i].split(":");
            map.put(keyValue[0],keyValue[1]);
            System.out.println(keyValue[0]+","+keyValue[1]);
            }else{
                String keyValue[]= sArr[i].split(":");
                map.put(keyValue[0],keyValue[2]);
            }
        }
        return map;
    }
 
    }

В следующем листинге показан контент для объекта- переносчика класса CarTO

CarTO.java

01
02
03
04
05
06
07
08
09
10
package mongo.db.to;
import java.util.Date;
public class CarTO {
    private String carName;
    private String company;
    private Integer cc;
    private Double price;
    private Date model;
    /*Getters and Setters to be coded*/
}

Если щелкнуть ссылку «Просмотреть зарегистрированные автомобили» на домашней странице, поскольку это командная ссылка, выполняется обработчик действия getCarDetails объекта CarBean, а сведения извлекаются из класса CarService с помощью метода findData. См. Код CarBean для обработчика действия getCarDetails. , Следующий листинг представляет код для Report.xhtml.

Report.xhtml.java

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml"
    xmlns:f="http://java.sun.com/jsf/core"
    xmlns:h="http://java.sun.com/jsf/html"
    xmlns:j="http://java.sun.com/jsp/jstl/core">
<h:head>
 
<meta http-equiv="content-type" content="text/html; charset=utf-8" />
 
</h:head>
 
<h:body>
 
<f:view>
<h:form>
 
<center>
<h2>MSD Car Portal</h2>
<h3>Car Details</h3>
 
<h:dataTable value="#{carBean.list}" var="item" border="2" rendered="#{not empty carBean.list}">
 
<h:column>
<f:facet name="header">
<h:outputText value="CarName"></h:outputText>
</f:facet>
<h:outputText value="#{item.carName}"></h:outputText>
</h:column>
 
<h:column>
<f:facet name="header">
<h:outputText value="Company"></h:outputText>
</f:facet>
<h:outputText value="#{item.company}"></h:outputText>
</h:column>
 
 
 
<h:column>
<f:facet name="header">
<h:outputText value="Model"></h:outputText>
</f:facet>
<h:outputText value="#{item.model.time}">
<f:convertDateTime pattern="dd-MMM-yyyy"></f:convertDateTime>
</h:outputText>
</h:column>
 
<h:column>
<f:facet name="header">
<h:outputText value="CC"></h:outputText>
</f:facet>
<h:outputText value="#{item.cc}"></h:outputText>
</h:column>
 
<h:column>
<f:facet name="header">
<h:outputText value="Price"></h:outputText>
</f:facet>
<h:outputText value="#{item.price}"></h:outputText>
</h:column>
                 
</h:dataTable>
                 
<br/><h:outputText value="#{carBean.message}"></h:outputText>
                 
<br/><h:outputLink value="Home.xhtml">Home</h:outputLink>
</center>
             
</h:form>
</f:view>
 
</h:body>
</html>

Вывод

Из приведенного примера становится ясно, что MongoDb можно интегрировать с существующими веб-фреймворками и использовать для создания веб-приложений, которые могут легко справляться с проблемами больших данных.

Ссылка:

43
Share: