#yashandb#
YCA认证免费报名： https://www.yashandb.com/YCA_courses
目录
1.1、使用JDBC驱动前须先安装JDK，JDK版本兼容信息如下： 2
前言：
继前两天安装了个人单机版之后，从此一发不可收。本文继续小试牛刀，简单介绍一下通过java脚本操作YashanDB。
【YashanDB认证】崖山数据库单机版安装（Kylin V10+YashanDB Personal 23.2.3）
一、环境介绍
1.1、使用JDBC驱动前须先安装JDK，JDK版本兼容信息如下：
JDK：1.8及以上
JRE：1.8及以上
1.2、检查 JDK 是否已安装
首先，你需要确认 JDK 是否已经安装在你的系统上。你可以通过在终端中运行以下命令“java -version”来检查 Java 运行环境（JRE）是否安装（JDK 包含 javac 编译器，而 JRE 只包含运行 Java 程序的运行时环境）。
--查看当前java 版本信息 $ java –version |
-- JDK 没有安装，你可以通过你的 Linux 发行版的包管理器来安装它 sudo yum install java-1.8.0-openjdk-devel |
二、JDBC驱动安装
2.1、JDBC驱动下载地址
https://download.yashandb.com/download
2.2、配置目录及JDBC驱动环境
cd /home/yashan mkdir jdbc cd jdbc --增加环境变量：export CLASSPATH=/home/yashan/jdbc/yashandb-jdbc-1.6.9.jar:${CLASSPATH} vi ~/.bashrc --生效环境变量 source ~/.bashrc |
三、编写java文件并测试
3.1、编写java文件
vi Jdbcexample.java |
--java文件内容（主要包括3件事：连接数据库、创建customer表、向表中写入数据）
package jdbc0; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; import java.sql.Statement; import java.sql.CallableStatement; public class Jdbcexample { public static Connection getConnection(String username, String passwd) { String driver = "com.yashandb.jdbc.Driver"; String sourceURL = "jdbc:yasdb://192.168.52.7:1688/yasdb"; Connection conn = null; try { Class.forName(driver); } catch (Exception e) { e.printStackTrace(); return null; } try { conn = DriverManager.getConnection(sourceURL, username, passwd); System.out.println("Connection succeed!"); } catch (Exception e) { e.printStackTrace(); return null; } return conn; }
public static void createTable(Connection conn) { Statement stmt = null; try { stmt = conn.createStatement(); stmt.execute("DROP TABLE IF EXISTS customer"); stmt.execute("CREATE TABLE customer(id INTEGER, name VARCHAR(32))"); System.out.println("create table customer succeed!"); stmt.close(); } catch (SQLException e) { if (stmt != null) { try { stmt.close(); } catch (SQLException e1) { e1.printStackTrace(); } } e.printStackTrace(); } }
public static void batchInsertData(Connection conn) { PreparedStatement pst = null; try { pst = conn.prepareStatement("INSERT INTO customer VALUES (?,?)"); for (int i = 0; i < 3; i++) { pst.setInt(1, i); pst.setString(2, "sales" + i); pst.addBatch(); } pst.executeBatch(); System.out.println("insert table customer succeed!"); pst.close(); } catch (SQLException e) { if (pst != null) { try { pst.close(); } catch (SQLException e1) { e1.printStackTrace(); } } e.printStackTrace(); } }
public static int execJdbcexample(String ctrls) { Connection conn = getConnection("sys", "Yas#1234"); createTable(conn); batchInsertData(conn); try { conn.close(); } catch (SQLException e) { e.printStackTrace(); return 0; } return 1; } public static void main(String[] args) { int a = execJdbcexample("1"); } } |
Tip：替换jdbc连接字符串信息、数据库用户、密码登信息。
3.2、编译java文件并执行
--编译 javac -d . Jdbcexample.java --执行 java -cp .:yashandb-jdbc-1.6.9.jar jdbc0.Jdbcexample |
3.3、验证java脚本运行结果
通过客户端登录，查看java中的执行内容是否成功。
--本次测到此结束~
