NoSql数据库mongoDB和MySQL的比较

NoSQL 前端之家
前端之家收集整理的这篇文章主要介绍了NoSql数据库mongoDB和MySQL的比较，前端之家小编觉得挺不错的，现在分享给大家，也给大家做个参考。

下面是代码：

MysqL插入

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
import java.util.Random;

public class AddData {

    public static void main(String[] args) throws Exception {
        Connection connection;
        Statement statement;

        Class.forName("com.MysqL.jdbc.Driver");
        connection = DriverManager.getConnection("jdbc:MysqL://localhost:3306/test","root","");
        statement = connection.createStatement();

        // 清理表
        statement.executeUpdate("truncate table flt_evecurrent");

        // 增加记录
        Random random = new Random(System.currentTimeMillis());
        for (int fltId = 0; fltId < 1000000; fltId++) {
            if ((fltId % 10000) == 0) {
                System.out.println(fltId);
            }
            int nodeId = 0;
            int objId = random.nextInt(100);
            int stationId = objId;
            int eveType = 0;
            int severity = 0;
            String reportTime = String.format("2010-09-%d",fltId / 100000 + 1);
            String createTime = reportTime;
            String eveContent = "ContentContentContent";
            String eveDesc = "DescDescDesc";
            String sql = String.format("insert into flt_evecurrent (NodeID,FltID,ObjID,StationID,EveType,Severity,ReportTime,CreateTime,EveContent,EveDesc) "
                    + "values (%d,%d,'%s','%s')",nodeId,fltId,objId,stationId,eveType,severity,reportTime,createTime,eveContent,eveDesc);
            statement.executeUpdate(sql);
        }

        statement.close();
        connection.close();
    }
}

MySQL查询

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.sqlException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;

public class PerfTest {

    public PerfTest() {
    }

    @BeforeClass
    public static void setUpClass() throws Exception {
    }

    @AfterClass
    public static void tearDownClass() throws Exception {
    }

    @Test
    public void test() throws Exception {
        Class.forName("com.MysqL.jdbc.Driver");
//        final Connection connection = DriverManager.getConnection("jdbc:MysqL://localhost:3306/test","");

        List<Thread> threads = new ArrayList<Thread>();
        for (int i = 0; i < 100; i++) {
            Thread thread = new Thread(new Runnable() {

                public void run() {
                    Connection connection = null;
                    Statement statement = null;
                    ResultSet resultSet = null;
                    try {
                        connection = DriverManager.getConnection("jdbc:MysqL://localhost:3306/test","");
                        statement = connection.createStatement();
                        System.out.println(String.format("线程%d查询开始",Thread.currentThread().getId()));
                        resultSet = statement.executeQuery("select count(*) from flt_evecurrent where objid in (30,50,70) and createtime between '2010-09-03' and '2010-09-07'");
                        resultSet.first();
                        System.out.println(String.format("数量：%d",resultSet.getLong("count(*)")));
                        System.out.println(String.format("线程%d查询结束",Thread.currentThread().getId()));
                    } catch (Exception ex) {
                        Logger.getLogger(PerfTest.class.getName()).log(Level.SEVERE,null,ex);
                    } finally {
                        try {
                            connection.close();
                        } catch (sqlException ex) {
                            Logger.getLogger(PerfTest.class.getName()).log(Level.SEVERE,ex);
                        }
                    }
                }
            });
            thread.start();
            threads.add(thread);
        }

        for (Thread thread : threads) {
            thread.join();
        }

//        connection.close();
    }
}
MongoDB插入 
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.Mongo;
import java.util.Calendar;
import java.util.Date;
import java.util.Random;

public class AddData {

    public static void main(String[] args) throws Exception {
        Mongo mongo = new Mongo("localhost",27017);
        DB db = mongo.getDB("test");
        DBCollection coll = db.getCollection("flt_evecurrent");

        // 删除表
        coll.drop();

        // 增加索引
        coll.createIndex(new BasicDBObject("ObjID",1));
        coll.createIndex(new BasicDBObject("CreateTime",1));

        // 增加记录
        Random random = new Random(System.currentTimeMillis());
        Calendar calendar = Calendar.getInstance();
        for (int fltId = 0; fltId < 1000000; fltId++) {
            if ((fltId % 10000) == 0) {
                System.out.println(fltId);
            }
            int nodeId = 0;
            int objId = random.nextInt(100);
            int stationId = objId;
            int eveType = 0;
            int severity = 0;
            calendar.set(2010,9,fltId / 100000 + 1);
            Date reportTime = calendar.getTime();
            Date createTime = reportTime;
            String eveContent = "ContentContentContent";
            String eveDesc = "DescDescDesc";
            BasicDBObject obj = new BasicDBObject();
            obj.put("NodeID",nodeId);
            obj.put("FltID",fltId);
            obj.put("ObjID",objId);
            obj.put("StationID",stationId);
            obj.put("EveType",eveType);
            obj.put("Severity",severity);
            obj.put("ReportTime",reportTime);
            obj.put("CreateTime",createTime);
            obj.put("EveContent",eveContent);
            obj.put("EveDesc",eveDesc);
            coll.insert(obj);
        }
    }
}

MongoDB查询

import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.Mongo;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;

public class PerfTest {

    public PerfTest() {
    }

    @BeforeClass
    public static void setUpClass() throws Exception {
    }

    @AfterClass
    public static void tearDownClass() throws Exception {
    }

    @Test
    public void test() throws Exception {
        // 增大Mongo驱动的并发连接数量
        System.setProperty("MONGO.POOLSIZE","1000");

        Mongo mongo = new Mongo("localhost",27017);
        DB db = mongo.getDB("test");
        final DBCollection coll = db.getCollection("flt_evecurrent");

        Calendar calendar = Calendar.getInstance();
        calendar.set(2010,3);
        Date beginTime = calendar.getTime();
        calendar.set(2010,7);
        Date endTime = calendar.getTime();
        List objIds = new ArrayList();
        objIds.add(30);
        objIds.add(50);
        objIds.add(70);
        final BasicDBObject query = new BasicDBObject();
        query.put("CreateTime",new BasicDBObject("$gte",beginTime).append("$lte",endTime));
        query.put("ObjID",new BasicDBObject("$in",objIds));

        List<Thread> threads = new ArrayList<Thread>();
        for (int i = 0; i < 100; i++) {
            Thread thread = new Thread(new Runnable() {

                public void run() {
                    System.out.println(String.format("线程%d查询开始",Thread.currentThread().getId()));
                    long count = coll.getCount(query);
                    System.out.println(String.format("数量：%d",count));
                    System.out.println(String.format("线程%d查询结束",Thread.currentThread().getId()));
                }
            });
            thread.start();
            threads.add(thread);
        }

        for (Thread thread : threads) {
            thread.join();
        }
    }
}

MysqL的建表语句

-- MyISAM无索引
DROP TABLE `flt_evecurrent`;
CREATE TABLE `flt_evecurrent` (
  `NodeID` int(11) NOT NULL DEFAULT '0',`FltID` int(11) NOT NULL DEFAULT '0',`ObjID` int(11) DEFAULT NULL,`StationID` int(11) DEFAULT NULL,`EveType` int(11) DEFAULT NULL,`Severity` int(11) DEFAULT NULL,`ReportTime` date DEFAULT NULL,`CreateTime` date DEFAULT NULL,`EveContent` varchar(1024) DEFAULT NULL,`EveDesc` varchar(256) DEFAULT NULL,PRIMARY KEY (`NodeID`,`FltID`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8;

-- MyISAM有索引
DROP TABLE `flt_evecurrent`;
CREATE TABLE `flt_evecurrent` (
  `NodeID` int(11) NOT NULL DEFAULT '0',`FltID`),KEY `ObjID` (`ObjID`),KEY `CreateTime` (`CreateTime`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8;

-- InnoDB无索引
DROP TABLE `flt_evecurrent`;
CREATE TABLE `flt_evecurrent` (
  `NodeID` int(11) NOT NULL DEFAULT '0',`FltID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

-- InnoDB有索引
DROP TABLE `flt_evecurrent`;
CREATE TABLE `flt_evecurrent` (
  `NodeID` int(11) NOT NULL DEFAULT '0',KEY `CreateTime` (`CreateTime`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

猜你在找的NoSQL相关文章

Redis进阶实践之十八 使用管道模式提高Redis查询的速度
一、引言 学习redis 也有一段时间了，该接触的也差不多了。后来有一天，以前的同事问我，如...
MongoDb进阶实践之二 如何在Windows上安装和配置MongoDB
一、引言 上一篇文章，我介绍了如何在Linux系统上安装和配置MongoDB，其实都不是很难，不需...
Redis进阶实践之十七 Redis协议的规范
一、介绍 Redis客户端使用RESP（Redis的序列化协议）协议与Redis的服务器端进行通信。 虽然...
Redis进阶实践之十九 Redis如何使用lua脚本
一、引言 redis学了一段时间了，基本的东西都没问题了。从今天开始讲写一些redis和lua脚本...
Redis进阶实践之十五 Redis-cli命令行工具使用详解第二部分（结束）
一、介绍 今天继续redis-cli使用的介绍，上一篇文章写了一部分，写到第9个小节，今天就来完...
Redis进阶实践之十四 Redis-cli命令行工具使用详解第一部分
一、介绍 redis学了有一段时间了，以前都是看视频，看教程，很少看官方的东西。现在redis的...
MongoDb进阶实践之七 MongoDB的索引入门
一、引言 好久没有写东西了，MongoDB系列的文章也丢下好长时间了。今天终于有时间了，就写...
Memcached在Linux环境下的使用详解
一、引言 写有关NoSQL数据库有关的文章已经有一段时间了，可以高兴的说，Redis暂时就算写完...
Redis进阶实践之二十 Redis的配置文件使用详解
一、引言 写完上一篇有关redis使用lua脚本的文章，就有意结束Redis这个系列的文章了，当然...
Redis进阶实践之十二 Redis的Cluster集群动态扩容
一、引言 上一篇文章我们一步一步的教大家搭建了Redis的Cluster集群环境，形成了3个主节点...
MySQLMsSQLOracleSqlitePostgre SQLMariadbMongoDBNoSQLHBaseJDBC
undo日志persistent-cmysql-error-postal-codesql-match-almysql-5.6mysql-8.0database-tri安装路径系统错误data_dir丢失文件主从同步sql_mode数据库目录匿名用户character_seID归零数据库位置查询表重复字段查询字段截断日志SUSPECT7391Remote ServeLinked Serve玄学问题登录不上开启远程访问