共享文件夹的.db文件如何读取出来java

共享文件夹的.db文件如何读取出来java,第1张

共享文件夹的db文件如何读取出来java:创建libs文件夹放入后,解压包:file-project-structure-dependencies 点击右上角+号,选jars即可。

如果有报错红线,鼠标放上去:more actions-surround with try/catach

导入包

import javasql;

public static Connection getCon(){

ClassforName("这里放连接字符串");

Connection conn = DriverManagergetConnections("这里放连接驱动","登录数据库的用户名","密码");

}

这样一个方法就可以连接数据库

public static ResultSet select(){

PreparedStatement pstmt = getCon()preparedStatement("SQL语句");

ResultSet rs = pstmtexecuteQuerry();

return rs;

}

这样就可以对数据库的数据进行查询

public static int select(){

PreparedStatement pstmt = getCon()preparedStatement("SQL语句");

int rs = pstmtexecuteUpdate();

/if (rs > 0 )

执行成功,写你的业务方法

else

没有执行成功,写你的业务方法/

return rs;

}

这是执行增删改的方法

HelloWorld程序

学习任何程序的第一步,都是编写HelloWorld程序,我们也不例外,看下如何通过Java编写一个HelloWorld的程序。

首先,要通过Java *** 作Mongodb,必须先下载Mongodb的Java驱动程序,可以在这里下载。

新建立一个Java工程,将下载的驱动程序放在库文件路径下,程序代码如下:

package commkyongcore;

import javanetUnknownHostException;

import commongodbBasicDBObject;

import commongodbDB;

import commongodbDBCollection;

import commongodbDBCursor;

import commongodbMongo;

import commongodbMongoException;

/

 Java + MongoDB Hello world Example

 

/

public class App {

    public static void main(String[] args) {

        try {

            //实例化Mongo对象,连接27017端口

            Mongo mongo = new Mongo("localhost", 27017);

                               //连接名为yourdb的数据库,假如数据库不存在的话,mongodb会自动建立

            DB db = mongogetDB("yourdb");

            // Get collection from MongoDB, database named "yourDB"

//从Mongodb中获得名为yourColleection的数据集合,如果该数据集合不存在,Mongodb会为其新建立

            DBCollection collection = dbgetCollection("yourCollection");

    // 使用BasicDBObject对象创建一个mongodb的document,并给予赋值。

            BasicDBObject document = new BasicDBObject();

            documentput("id", 1001);

            documentput("msg", "hello world mongoDB in Java");

            //将新建立的document保存到collection中去

            collectioninsert(document);

            // 创建要查询的document

            BasicDBObject searchQuery = new BasicDBObject();

            searchQueryput("id", 1001);

            // 使用collection的find方法查找document

            DBCursor cursor = collectionfind(searchQuery);

            //循环输出结果

            while (cursorhasNext()) {

            Systemoutprintln(cursornext());

            }

            Systemoutprintln("Done"); 

        } catch (UnknownHostException e) {

            eprintStackTrace();

        } catch (MongoException e) {

            eprintStackTrace();

        }

    }

}

最后,输出的结果为:

{ "_id" : { "$oid" : "4dbe5596dceace565d229dc3"} , 

                "id" : 1001 , "msg" : "hello world mongoDB in Java"}

Done

在上面的例子中,演示了使用Java对Mongodb *** 作的重要方法和步骤,首先通过创建Mongodb对象,传入构造函数的参数是Mongodb的数据库所在地址和端口,然后使用

getDB方法获得要连接的数据库名,使用getCollection获得数据集合的名,然后通过新建立BasicDBObject对象去建立document,最后通过collection的insert方法,将建立的document保存到数据库中去。而collection的find方法,则是用来在数据库中查找document。

从Mongodb中获得collection数据集

在Mongodb中,可以通过如下方法获得数据库中的collection:

DBCollection collection = dbgetCollection("yourCollection");

如果你不知道collection的名称,可以使用dbgetCollectionNames()获得集合,然后再遍历,如下:

DB db = mongogetDB("yourdb");

Set collections = dbgetCollectionNames();

for(String collectionName : collections){

Systemoutprintln(collectionName);

}

完成的一个例子如下:

package commkyongcore;

import javanetUnknownHostException;

import javautilSet;

import commongodbDB;

import commongodbDBCollection;

import commongodbMongo;

import commongodbMongoException;

/

 Java : Get collection from MongoDB

 

/

public class GetCollectionApp {

public static void main(String[] args) {

try {

Mongo mongo = new Mongo("localhost", 27017);

DB db = mongogetDB("yourdb");

Set<String> collections = dbgetCollectionNames();

for (String collectionName : collections) {

Systemoutprintln(collectionName);

}

DBCollection collection = dbgetCollection("yourCollection");

Systemoutprintln(collectiontoString());

Systemoutprintln("Done");

} catch (UnknownHostException e) {

eprintStackTrace();

} catch (MongoException e) {

eprintStackTrace();

}

}

}

Mongodb中如何插入数据

下面,讲解下如何使用4种方式,将JSON数据插入到Mongodb中去。首先我们准备JSON

格式的数据,如下:

 

 {

"database" : "mkyongDB",

"table" : "hosting",

"detail" :

{

records : 99,

index : "vps_index1",

active : "true"

}

}

}

我们希望用不同的方式,通过JAVA代码向Mongodb插入以上格式的JSON数据

第一种方法,是使用BasicDBObject,方法如下代码所示:

BasicDBObject document = new BasicDBObject();

documentput("database", "mkyongDB");

documentput("table", "hosting");

BasicDBObject documentDetail = new BasicDBObject();

documentDetailput("records", "99");

documentDetailput("index", "vps_index1");

documentDetailput("active", "true");

documentput("detail", documentDetail);

collectioninsert(document);

第二种方法是使用BasicDBObjectBuilder对象,如下代码所示:

BasicDBObjectBuilder documentBuilder = BasicDBObjectBuilderstart()

add("database", "mkyongDB")

add("table", "hosting");

BasicDBObjectBuilder documentBuilderDetail = BasicDBObjectBuilderstart()

add("records", "99")

add("index", "vps_index1")

add("active", "true");

documentBuilderadd("detail", documentBuilderDetailget());

collectioninsert(documentBuilderget());

第三种方法是使用Map对象,代码如下:

 

 Map documentMap =new HashMap();

documentMapput("database", "mkyongDB");

documentMapput("table", "hosting");

Map documentMapDetail =new HashMap();

documentMapDetailput("records", "99");

documentMapDetailput("index", "vps_index1");

documentMapDetailput("active", "true");

documentMapput("detail", documentMapDetail);

collectioninsert(new BasicDBObject(documentMap));

第四种方法,也就是最简单的,即直接插入JSON格式数据

String json ="{'database' : 'mkyongDB','table' : 'hosting',"+

"'detail' : {'records' : 99, 'index' : 'vps_index1', 'active' : 'true'}}}";

DBObject dbObject =(DBObject)JSONparse(json);

collectioninsert(dbObject);

这里使用了JSON的parse方法,将解析后的JSON字符串转变为DBObject对象后再直接插入到collection中去。

完整的代码如下所示:

packagecommkyongcore;

importjavanetUnknownHostException;

importjavautilHashMap;

importjavautilMap;

importcommongodbBasicDBObject;

importcommongodbBasicDBObjectBuilder;

importcommongodbDB;

importcommongodbDBCollection;

importcommongodbDBCursor;

importcommongodbDBObject;

importcommongodbMongo;

importcommongodbMongoException;

importcommongodbutilJSON;

/

Java MongoDB : Insert a Document

/

publicclass InsertDocumentApp {

publicstaticvoid main(String[] args){

try{

Mongo mongo =new Mongo("localhost", 27017);

DB db = mongogetDB("yourdb");

// get a single collection

DBCollection collection = dbgetCollection("dummyColl");

// BasicDBObject example

Systemoutprintln("BasicDBObject example");

BasicDBObject document =new BasicDBObject();

documentput("database", "mkyongDB");

documentput("table", "hosting");

BasicDBObject documentDetail =new BasicDBObject();

documentDetailput("records", "99");

documentDetailput("index", "vps_index1");

documentDetailput("active", "true");

documentput("detail", documentDetail);

collectioninsert(document);

DBCursor cursorDoc = collectionfind();

while(cursorDochasNext()){

Systemoutprintln(cursorDocnext());

}

collectionremove(new BasicDBObject());

// BasicDBObjectBuilder example

Systemoutprintln("BasicDBObjectBuilder example");

BasicDBObjectBuilder documentBuilder = BasicDBObjectBuilderstart()

add("database", "mkyongDB")

add("table", "hosting");

BasicDBObjectBuilder documentBuilderDetail = BasicDBObjectBuilderstart()

add("records", "99")

add("index", "vps_index1")

add("active", "true");

documentBuilderadd("detail", documentBuilderDetailget());

collectioninsert(documentBuilderget());

DBCursor cursorDocBuilder = collectionfind();

while(cursorDocBuilderhasNext()){

Systemoutprintln(cursorDocBuildernext());

}

collectionremove(new BasicDBObject());

// Map example

Systemoutprintln("Map example");

Map documentMap =new HashMap();

documentMapput("database", "mkyongDB");

documentMapput("table", "hosting");

Map documentMapDetail =new HashMap();

documentMapDetailput("records", "99");

documentMapDetailput("index", "vps_index1");

documentMapDetailput("active", "true");

documentMapput("detail", documentMapDetail);

collectioninsert(new BasicDBObject(documentMap));

DBCursor cursorDocMap = collectionfind();

while(cursorDocMaphasNext()){

Systemoutprintln(cursorDocMapnext());

}

collectionremove(new BasicDBObject());

// JSON parse example

Systemoutprintln("JSON parse example");

String json ="{'database' : 'mkyongDB','table' : 'hosting',"+

"'detail' : {'records' : 99, 'index' : 'vps_index1', 'active' : 'true'}}}";

DBObject dbObject =(DBObject)JSONparse(json);

collectioninsert(dbObject);

DBCursor cursorDocJSON = collectionfind();

while(cursorDocJSONhasNext()){

Systemoutprintln(cursorDocJSONnext());

}

collectionremove(new BasicDBObject());

}catch(UnknownHostException e){

eprintStackTrace();

}catch(MongoException e){

eprintStackTrace();

}

}

}

 

package comcxiaolnginsert;

import javaioBufferedReader;

import javaioFile;

import javaioFileReader;

import javasqlConnection;

import javasqlDriverManager;

import javasqlSQLException;

import javasqlStatement;

public class ReadToInsert {

private static Connection connection;

final static String url = "jdbc:mysql://localhost:3306/test";

static {

// 加载驱动程序以连接数据库

try {

ClassforName("orggjtmmmysqlDriver");

connection = DriverManagergetConnection(url, "root", "admin");

} catch (ClassNotFoundException e) {

// 捕获加载驱动程序异常

Systemerrprintln("装载 JDBC/ODBC 驱动程序失败。");

eprintStackTrace();

Systemexit(1); // terminate program

} catch (SQLException e) {

// 捕获连接数据库异常

Systemerrprintln("无法连接数据库");

eprintStackTrace();

Systemexit(1); // terminate program

}

}

public static void main(String[] args) {

Statement statement = null;

File file = new File("folder/data1txt");

if (fileisFile()) {

try {

statement = connectioncreateStatement();

BufferedReader br = new BufferedReader(new FileReader(file));

while (brready()) {

StringBuffer resultStr = new StringBuffer();

resultStrdelete(0, resultStrlength());

resultStrappend(brreadLine());

String sql = "insert into test(content) values('"+resultStrtoString()+"')";

statementexecute(sql);

}

} catch (Exception e) {

Systemoutprintln("插入数据异常"+e);

eprintStackTrace();

}

}

try{

if(!statementisClosed()){

statementclose();

}

if(!connectionisClosed()){

connectionclose();

}

}catch(Exception e){

eprintStackTrace();

}

}

}

接分啊。。。

这个和你的db文件数据格式有关吧。

BufferedReader、BufferedWriter 是采用字符流读写,字符流通常用来读取数据并显示出来。

应该用字节流来读写,反正是写到另一个文件去:

new BufferedInputStream( new FileInputStream(

用BufferedOutputStream来写。

由于您的问题不太明确,我无法理解您想要的是什么。但是,我可以提供您几个运行JavaWeb DBCreate的结果的可能性:

- 如果成功地运行了JavaWeb DBCreate,则应该会在数据库中创建相应的表和字段,从而允许您使用已定义的模式来存储数据。

- 如果出现数据库连接错误,则DBCreate将无法与数据库建立连接,可能会显示相应的错误消息。

- 如果您输入了错误的数据库信息,例如使用了错误的端口号、主机名或用户名/密码,则DBCreate也会显示错误消息,因为它无法连接到数据库。

- 请注意,如果表已经存在,DBCreate可能会出现错误消息,因为它不能重新创建一张已经存在的表。

这些只是一些可能的结果,具体结果会因为您的代码和环境而有所不同。

很多人都在知道,计算机行业的发展是非常迅速的,软件开发人员想要跟上时代的发展,最重要的就是不断挑战自己。在学习软件开发的过程,前期学习的知识是远远不够的,需要了解更多的知识,并且挑战更多的复杂性。

现在学习Java语言不能忽略工具和框架的使用,工具和框架的构建越来越复杂。很多人不知道学习工具和框架有什么用?下面昌平电脑培训为大家具体了解Java开发应该了解的大数据工具和框架。

一、MongoDB

这是一种最受欢迎的,跨平台的,面向文档的数据库。

MongoDB的核心优势是灵活的文档模型,高可用性复制集和可扩展的碎片集群。北京java培训建议可以尝试以多种方式了解MongoDB,例如MongoDB工具的实时监控,内存使用和页面错误,连接,数据库 *** 作,复制集等。

二、Elasticsearch

主要是能够为云构建的分布式RESTful搜索引擎。

Elasticsearch主要是使用在Lucene之中的服务器,能够进行分布式多用户能力的全文搜索引擎,并且还是使用在Java的开发中,这是现在很多企业中使用最流行的搜索引擎。ElasticSearch不仅是一个全文搜索引擎,而且是一个分布式实时文档存储,每个字段都能够被索引并且可以被搜索。它也是一个具有实时分析功能的分布式搜索引擎,java课程发现它还可以扩展到数百个服务器存储和处理数PB的数据。

三、Cassandra

这是一个开源的分布式数据库管理系统,最初由Facebook开发,用于处理许多商用服务器上的大量数据,提供高可用性而无单点故障。

ApacheCassandra是一套开源分布式NoSQL数据库系统。集GoogleBigTable的数据模型与AmazonDynamo的完全分布式架构于一身。于2008开源,此后,由于Cassandra良好的可扩展性,被Digg、Twitter等Web20网站所采纳,成为了一种流行的分布式结构化数据存储方案。

四、Redis

开源(BSD许可证)内存数据结构存储,用作数据库,缓存和消息代理。

Redis是一个开源的,基于日志的Key-Value数据库,用ANSIC编写,支持网络,可以基于内存持久化,并提供多种语言的API。Redis有三个主要功能,北京IT培训认为可以将它与许多其他竞争对手区分开来:Redis是一个将数据完全存储在内存中的数据库,仅使用磁盘用于持久性目的。

以上就是关于共享文件夹的.db文件如何读取出来java全部的内容,包括:共享文件夹的.db文件如何读取出来java、怎么用JAVA对DB文件 *** 作、如何用Java *** 作MongoDB等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!

欢迎分享,转载请注明来源:内存溢出

原文地址:https://54852.com/web/9544679.html

(0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
上一篇 2023-04-29
下一篇2023-04-29

发表评论

登录后才能评论

评论列表(0条)

    保存