
共享文件夹的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等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)