全部栏目

首页 旅游资讯 线路攻略 景点大全 国内游 境外游 美食特产

如何使用JAVA创建数据库表。

发布网友 发布时间：2022-04-20 07:45

我来回答

共4个回答

懂视网 时间：2022-04-08 12:45

Java在HBase数据库创建表

作者：chszs，版权所有，未经同意，不得转载。博主主页：http://blog.csdn.net/chszs

要通过Java在HBase中创建一个数据表，首先需要导入hbase-client.jar驱动包。可以在项目pom.xml配置文件中添加依赖：

<dependency>
 <groupId>org.apache.hbase</groupId>
 <artifactId>hbase-client<artifactId>
 <version>1.1.0.1</version>
<dependency>

在添加依赖后，我们需要创建Configuration对象，并指定core-site.xml和hbase-site.xml作为资源文件。

Configuration config = HBaseConfiguration.create();
config.addResource(new Path("/etc/hbase/conf/hbase-site.xml"));
config.addResource(new Path("/etc/hadoop/conf/core-site.xml"));

还需要在Configuration对象中设置hbase.zookeeper.quorum参数和hbase.zookeeper.property.clientPort参数的值，这些值也可以在hbase-site.xml配置文件中找到：

Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "127.0.0.1");
config.set("hbase.zookeeper.property.clientPort", "2181");

Configuration对象创建完成后，接着创建连接到HBase数据库的Connection对象，并通过此对象获取Admin对象，它负责实现创建数据表的操作：

Connection connection = ConnectionFactory.createConnection(config);
Admin admin = connection.getAdmin();

一旦创建了Admin对象后，可以通过下面的代码创建数据表了：

String tableName = "users";

if (!admin.isTableAvailable(TableName.valueOf(tableName))) {
 HTableDescriptor hbaseTable = new HTableDescriptor(TableName.valueOf(tableName));
 hbaseTable.addFamily(new HColumnDescriptor("name"));
 hbaseTable.addFamily(new HColumnDescriptor("contact_info"));
 hbaseTable.addFamily(new HColumnDescriptor("personal_info"));
 admin.createTable(hbaseTable);
}

会严重是否存在“users”名的数据表，如果此表不存在就会创建一个新表，列名包括：家庭名、联系信息和个人信息。

完整的程序如下：

package com.wordpress.khodeprasad;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;

/**
* @author Prasad Khode
*
*/
public class CreateTable {

 public static void main(String[] args) {
 CreateTable object = new CreateTable();
 object.createTable();
 }

 public void createTable() {
 Configuration config = HBaseConfiguration.create();
 config.set("hbase.zookeeper.quorum", "127.0.0.1");
 config.set("hbase.zookeeper.property.clientPort", "2181");

 Connection connection = null;
 Admin admin = null;

 try {
  connection = ConnectionFactory.createConnection(config);
  admin = connection.getAdmin();

  String tableName = "users";

  if (!admin.isTableAvailable(TableName.valueOf(tableName))) {
  HTableDescriptor hbaseTable = new HTableDescriptor(TableName.valueOf(tableName));
  hbaseTable.addFamily(new HColumnDescriptor("name"));
  hbaseTable.addFamily(new HColumnDescriptor("contact_info"));
  hbaseTable.addFamily(new HColumnDescriptor("personal_info"));
  admin.createTable(hbaseTable);
  }
 } catch (Exception e) {
  e.printStackTrace();
 } finally {
  try {
  if (admin != null) {
   admin.close();
  }

  if (connection != null && !connection.isClosed()) {
   connection.close();
  }
  } catch (Exception e2) {
  e2.printStackTrace();
  }
 }
 }
}

版权声明：本文为博主chszs的原创文章，未经博主允许不得转载。

Java在HBase数据库创建表

标签：hbase

热心网友 时间：2022-04-08 09:53

JDBC连接数据库
•创建一个以JDBC连接数据库的程序，包含7个步骤：
1、加载JDBC驱动程序：
在连接数据库之前，首先要加载想要连接的数据库的驱动到JVM（Java虚拟机），
这通过java.lang.Class类的静态方法forName(String className)实现。
例如：
try{
//加载MySql的驱动类
Class.forName("com.mysql.jdbc.Driver") ;
}catch(ClassNotFoundException e){
System.out.println("找不到驱动程序类 ，加载驱动失败！");
e.printStackTrace() ;
}
成功加载后，会将Driver类的实例注册到DriverManager类中。
2、提供JDBC连接的URL
•连接URL定义了连接数据库时的协议、子协议、数据源标识。
•书写形式：协议：子协议：数据源标识
协议：在JDBC中总是以jdbc开始
子协议：是桥连接的驱动程序或是数据库管理系统名称。
数据源标识：标记找到数据库来源的地址与连接端口。
例如：（MySql的连接URL）
jdbc:mysql:
//localhost:3306/test?useUnicode=true&characterEncoding=gbk ;
useUnicode=true：表示使用Unicode字符集。如果characterEncoding设置为
gb2312或GBK，本参数必须设置为true 。characterEncoding=gbk：字符编码方式。
3、创建数据库的连接
•要连接数据库，需要向java.sql.DriverManager请求并获得Connection对象，
该对象就代表一个数据库的连接。
•使用DriverManager的getConnectin(String url , String username ,
String password )方法传入指定的欲连接的数据库的路径、数据库的用户名和
密码来获得。
例如：
//连接MySql数据库，用户名和密码都是root
String url = "jdbc:mysql://localhost:3306/test" ;
String username = "root" ;
String password = "root" ;
try{
Connection con =
DriverManager.getConnection(url , username , password ) ;
}catch(SQLException se){
System.out.println("数据库连接失败！");
se.printStackTrace() ;
}
4、创建一个Statement
•要执行SQL语句，必须获得java.sql.Statement实例，Statement实例分为以下3
种类型：
1、执行静态SQL语句。通常通过Statement实例实现。
2、执行动态SQL语句。通常通过PreparedStatement实例实现。
3、执行数据库存储过程。通常通过CallableStatement实例实现。
具体的实现方式：
Statement stmt = con.createStatement() ;
PreparedStatement pstmt = con.prepareStatement(sql) ;
CallableStatement cstmt =
con.prepareCall("{CALL demoSp(? , ?)}") ;

热心网友 时间：2022-04-08 11:11

用PreparedStatement或Statement来执行,连接自己写好,execute("create sql语句"),就是这个思路了`.

热心网友 时间：2022-04-08 12:46

给你一段我写过的代码
你自己参考
照着写sql语句
public static User select(String name,String pass){
User vo=new User();
Connection conn=null;
PreparedStatement ps=null;
ResultSet rs=null;
String sql=" select username,password,flag from web_user where username='"+name+"' and password='"+pass+"' ";
try{
conn=DBUtil.getconnection();
ps=conn.prepareStatement(sql);
rs=ps.executeQuery();
if(rs.next()){
vo.setUsername(name);
vo.setPassword(pass);
vo.setFlag(rs.getInt("flag"));
return vo;
}
}catch(Exception e1){
try{
conn.rollback();
}catch(Exception e2){
e2.printStackTrace();
}
e1.printStackTrace();
System.out.println("查询失败");
}finally{
try{
rs.close();
ps.close();
conn.close();
}catch(Exception e3){
e3.printStackTrace();
}
}
vo=null;
return vo;
}
你创建表就是create table呗
不明白再问我 我这学过的例子程序多的是

声明声明：本网页内容为用户发布，旨在传播知识，不代表本网认同其观点，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。E-MAIL:11247931@qq.com
10.659186s