如何使用Hadoop读写数据库

1、选择开始菜单中→程序→Management SQL Server 2008→SQL Server Management Studio命令，打开SQL Server Management Studio窗口，并使用Windows或 SQL Server身份验证建立连接。

2、在对象资源管理器窗口中展开服务器，然后选择数据库节点

3、右键单击数据库节点，从d出来的快捷菜单中选择新建数据库命令。

4、执行上述 *** 作后，会d出新建数据库对话框。在对话框、左侧有3个选项，分别是常规、选项和文件组。完成这三个选项中的设置会后，就完成了数据库的创建工作，

5、在数据库名称文本框中输入要新建数据库的名称。例如，这里以“新建的数据库”。

6、在所有者文本框中输入新建数据库的所有者，如sa。根据数据库的使用情况，选择启用或者禁用使用全文索引复选框。

7、在数据库文件列表中包括两行，一行是数据库文件，而另一行是日记文件。通过单击下面的添加、删除按钮添加或删除数据库文件。

8、切换到选项页、在这里可以设置数据库的排序规则、恢复模式、兼容级别和其他属性。

9、切换到文件组页，在这里可以添加或删除文件组。

完成以上 *** 作后，单击确定按钮关闭新建数据库对话框。至此“新建的数据”数据库创建成功。新建的数据库可以再对象资源管理器窗口看到。

写Java程序时经常碰到要读如txt或写入txt文件的情况，但是由于要定义好多变量，经常记不住，每次都要查，特此整理一下，简单易用，方便好懂！

package eduthukeywordtest;  

import javaioFile;  

import javaioInputStreamReader;  

import javaioBufferedReader;  

import javaioBufferedWriter;  

import javaioFileInputStream;  

import javaioFileWriter;  

public class cin_txt {  

    static void main(String args[]) {  

        try { // 防止文件建立或读取失败，用catch捕捉错误并打印，也可以throw  

            / 读入TXT文件 /  

            String pathname = "D:\\twitter\\13_9_6\\dataset\\en\\inputtxt"; // 绝对路径或相对路径都可以，这里是绝对路径，写入文件时演示相对路径  

            File filename = new File(pathname); // 要读取以上路径的input。txt文件  

            InputStreamReader reader = new InputStreamReader(  

                    new FileInputStream(filename)); // 建立一个输入流对象reader  

            BufferedReader br = new BufferedReader(reader); // 建立一个对象，它把文件内容转成计算机能读懂的语言  

            String line = "";  

            line = brreadLine();  

            while (line != null) {  

                line = brreadLine(); // 一次读入一行数据  

            }  

            / 写入Txt文件 /  

            File writename = new File("\\result\\en\\outputtxt"); // 相对路径，如果没有则要建立一个新的output。txt文件  

            writenamecreateNewFile(); // 创建新文件  

            BufferedWriter out = new BufferedWriter(new FileWriter(writename));  

            outwrite("我会写入文件啦\r\n"); // \r\n即为换行  

            outflush(); // 把缓存区内容压入文件  

            outclose(); // 最后记得关闭文件  

        } catch (Exception e) {  

            eprintStackTrace();  

        }  

    }  

}

mysql导入导出常用命令

用mysql数据库最常用的功能便是导入导出了，当然用工具比较方便，不过，用命令你也是应该了解的。

以下实例在windows下的。

一、备份数据库：（命令在DOS的mysql\bin目录下执行，linux下当然不用到指定目录了）

mysqldump --opt school>schoolbbb

注释:将数据库school备份到schoolbbb文件，schoolbbb是一个文本文件，文件名任取，打开看看你会有新发现。

1导出整个数据库

mysqldump -u 用户名 -p 数据库名 > 导出的文件名

mysqldump -u root -p aikersql> aikersql

2导出一个表

mysqldump -u 用户名 -p 数据库名 表名> 导出的文件名

mysqldump -u aiker -p aikersql users> aiker_userssql

3导出一个数据库结构

mysqldump -u root -p -d --add-drop-table

aikersql>d:\aiker_dbsql

-d 没有数据 --add-drop-table 在每个create语句之前增加一个drop table

二导入数据库

常用source 命令

进入mysql数据库控制台，如mysql -u root -p

mysql>use 数据库

然后使用source命令，后面参数为脚本文件（如这里用到的sql）

mysql>source d:\aiker_dbsql

也可以用 mysql -uroot -Ddb1 <d:\aiker_dbsql

//定义驱动名

String url =

"jdbc:oracle:thin:@:1521:&&";//定义数据库的链接语句，表示你要链接的数据库的ip地址。当然如果你的本机上有oracle也可以写成127001或者localhost,"&&"表示你的数据库名称。Stringusername ="scott";

//你登陆数据库的用户名

String password ="";

//你登陆数据库的密码Stringsql= "insert into users(username,password)

values(,)";

//插入数据的命令语句try{

ClassforName(driver);Connectionconn = DriverManager getConnection_r(url,

username,password);

PreparedStatement

pstmt = connprepareStatement(sql);

pstmtsetString(1,

"god");

//当然为了方便我这是随便插入的数据

pstmtsetString(2,

"god");//同上

pstmtexecuteUpdate();

pstmtclose();

connclose();

//完成后关闭链接

} catch (ClassNotFoundException e) {

eprintStackTrace();

} catch (SQLExceptione) {

eprintStackTrace();}}}程序运行完成后你就会在你的数据库里看到多了一条记录username:god

password:god,另外我们觉得这篇博文的读者应该是那些对oracle数据库有一定的了解的程序开发爱好者源码天空

，如果你还不了解oracle,那你就需要对数据库有一定的了解这后再来看这篇博文。

对于一个热衷于程序设计的人来说，我们认为最主要的是你的程序一定要有一定的标准，我们认为这个例子是链接数据库最标准的方法。当然仁者见仁嘛

Cache吧，如果你文本读入后文件本身不被改变的话，你可以一次性读取出来放进hashtable

中再对hashtable进行处理，再然后写入数据库。读取一行就给行号，和值存储进hashtable里面，再作处理。

dim

s

as

object

=

scommexecutescalar

这句scomm已经执行过了

你下面就不能判断scommexecutescalar了

而是应该判断s是不是为null如果为null就说明执行没成功。

以上就是关于如何使用Hadoop读写数据库全部的内容，包括:如何使用Hadoop读写数据库、java如何从数据库读取数据并写入txt文件、读取sql文件并写入到数据库，用SQL语句。等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！