本文目录一览：
- 1、想用java编一个小程序可以实现mysql跟hbase的转换，需要看些什么书好呢？
- 2、怎样使我的Java小程序使用MySQL
- 3、如何在Java程序中访问mysql数据库中的数据并进行简单的操作
- 4、如何使用Java访问MySQL数据库
想用java编一个小程序可以实现mysql跟hbase的转换，需要看些什么书好呢？
为啥要看书捏，你需要了解hbase 的原理和存储方式以及设计方式，剩下的就是把mysql的数据导出为文件，然后上传到hdfs上，读取文件，将内容写入hbase，当然这只是其中一种方式，你还可以：
1、写mapreduce 直接读取mysql数据写入hbase
2、用hive将hbase 关联，将mysql的数据SYNC到hive中，在hbase中也就存在了。（SYNC是一个同步工具）
怎样使我的Java小程序使用MySQL
JDBC
加载JDBC驱动
与数据库建立连接
发送SQL语句，并得到返回结果
处理返回结果
MyBatis
使用MyBatis SQL映射语句
Hibernate
Hibernate与数据库的关联只需要在XML中配置即可
如何在Java程序中访问mysql数据库中的数据并进行简单的操作
import java.sql.*;
public class DBManager{
static Connection conn=null;
static{
System.out.println("in DBManager");
String dbName="ccrs";
try{
Class.forName("com.mysql.jdbc.Driver");
//配置数据源
String url="jdbc:mysql://192.168.1.2/"+ dbName +
"?useUnicode=truecharacterEncoding=GB2312";
conn=DriverManager.getConnection(url,"root","admin");
}catch(Exception e){
System.out.println("Exception:"+e.getMessage());
}
}
public synchronized static Connection getConnection(){
Connection temp=null;
if(conn!=null){
temp=conn;
conn=null;
return temp;
}else{
return null;
}
}
public synchronized static void releaseConnection(Connection con){
conn=con;
}
public static void closeConn(){
try{
conn.close();
}catch(SQLException e){
System.out.println(e.getMessage());
}
}
}
你要注意的地方:dbName为数据库名，你的mysql里面的数据库叫什么,这个就为什么,例如String dbName="yourDataBaseName";
Class.forName("com.mysql.jdbc.Driver"),这个就是你下的那个jar包,驱动
url="jdbc:mysql://localhost/"+ dbName +
"?useUnicode=truecharacterEncoding=GB2312"; //localhost数据库的机器名
conn=DriverManager.getConnection(url,"root","admin");
root是你数据库的用户名,admin为密码,你看你自己的数据库的用户名密码为多少,这里就为多少.
应该够详细了,还要注意的是你的驱动,即那个jar包你要放好,如果用eclipse的话导入你的工程属性里.不然的话加入classpath.你不是jsp,所以不用放进你的lib里.
如何使用Java访问MySQL数据库
第1步 获取Java与MySQL的连接器
第2步 将下载的包存放在自己机器上jdk安装目录下面的jre目录下面的lib目录下面的ext目录中，在程序中导入与数据库操作相关的对象
import java.sql.Connection; //导入数据库连接对象
import java.sql.DriverManager; //导入数据库驱动管理对象
import java.sql.ResultSet; //导入数据记录集对象
import java.sql.SQLException; //导入数据SQL操作异常对象
import java.sql.Statement; //导入SQL操作接口对象
第3步：在程序中写入如下内容
String url; //连接数据库的字符串
String sql; //执行数据sql查询操作的字符串
Connection conn; //数据库连接变量
Statement st; //数据库操作对象
ResultSet rs; //数据记录集对象
url = "jdbc:mysql://localhost:3306/test?user=rootpassword="; //在程序中只要修改这句，就可以实现数据库连接
try {
conn = DriverManager.getConnection(url);
st = conn.createStatement();
sql = "select * from test"; //只要修改这句，就可以实现各种查询操作
rs=st.executeQuery(sql); //执行数据查询
while(rs.next())
{
System.out.println(rs.getString(1)); //获得数据表test中第1个字段的数据，该字段为字符串类型
System.out.println(rs.getString(2)); //获得数据表test中第2个字段的数据，该字段为字符串类型
}
rs.close(); //关闭数据记录集
conn.close(); //关闭数据库连接
} catch (SQLException e) {
System.out.println("Error:"+e.toString()+e.getMessage());
}
