「YashanDB个人版体验」崖山数据库的增删查改DEMO

原创肖小可爱乐乐 2023-11-17

970

前言

本文适合想快速进入体验崖山数据库的开发者。你可以从文章里面有如下收获。

崖山数据库创建用户名、密码及相关权限。
从哪里下载崖山数据库的jdbc，下载后如何装进IDEA
配置JDBC的相关注意事项
对yashandb的增删查改的DEMO代码体验
jdbc对其它WEB框架的支持，目前的支持有限

准备环境

linux系统下崖山数据库个人版一个
windows下IDEA软件介质
yashandb-jdbc-1.5.1.jar

数据库环境

像使用Oracle一样使用yashandb，先创建数据库的用户名和密码。

SQL> CREATE USER xiao IDENTIFIED BY xiao1234;
Succeed.

SQL>GRANT connect to xiao;
Succeed.

SQL>ALTER USER xiao IDENTIFIED BY "xiao1234";
Succeed.

SQL>GRANT resource to xiao;
Succeed.

SQL>GRANT dba to xiao;
Succeed.

java下的增删查改开发

https://download.yashandb.com/download 下面找到 JAR对应的JDBC，如下

IDEA导入，点击Project Structure

选择+号

点击JAVA

选择JDBC驱动

确定应用

引用官方的代码如下，主要是修改JDBC连接串以及

com.yashandb.jdbc.Driver

jdbc:yasdb://192.168.153.128:1688/ya

package com.xiao;
import java.sql.*;

public class DemoYashan {
    //创建数据库连接。
    public static Connection getConnection(String username, String passwd) {
        String driver = "com.yashandb.jdbc.Driver";
        String sourceURL = "jdbc:yasdb://192.168.153.128:1688/ya";
        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;
    }

    //执行普通SQL语句，创建customer表。
    public static void createTable(Connection conn) {
        Statement stmt = null;
        try {
            stmt = conn.createStatement();

            //执行普通SQL语句。
            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 void selectDAta(Connection conn) {
        Statement stmt = null;
        try {
            stmt = conn.createStatement();

            //执行普通SQL语句。
            ResultSet resultSet =stmt.executeQuery("select * from customer");
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                System.out.println("ID: " + id + ", Name: " + name );
            }
            stmt.close();
        } catch (SQLException e) {
            if (stmt != null) {
                try {
                    stmt.close();
                } catch (SQLException e1) {
                    e1.printStackTrace();
                }
            }
            e.printStackTrace();
        }
    }

    public static void deleteDAta(Connection conn) {
        Statement stmt = null;
        try {
            stmt = conn.createStatement();

            //执行普通SQL语句。
            stmt.execute("delete  from customer");
            System.out.println("delete table customer succeed!");

            stmt.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public static int execJdbcexample(String ctrls) {
        //创建数据库连接。
        Connection conn = getConnection("xiao", "xiao1234");

        //创建表。
        createTable(conn);

        //批插数据。
        batchInsertData(conn);

        selectDAta(conn);
        deleteDAta(conn);
        //关闭数据库连接。
        try {
            conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
            return 0;
        }
        return 1;
    }

    /**
     * 主程序，逐步调用各静态方法。
     * @param args
     */
    public static void main(String[] args) {
    int a = execJdbcexample("1");
}
}