一、金仓数据库概述
金仓数据库的核心特点包括:
-
高性能:金仓数据库基于先进的存储引擎,能够处理大规模数据的存储和查询任务。其独特的分布式架构和高效的查询优化机制使得其在大数据、高并发的场景下依然能保持优异的性能表现。
-
高可靠性:金仓数据库支持多种高可用方案,包括主从复制、自动故障转移、数据备份和恢复等,确保了数据库系统的高可用性与数据的安全性。
-
强大的扩展性:金仓数据库能够横向扩展,支持分布式集群,适应不同规模的数据处理需求,可以根据用户的需求进行弹性扩展。
-
多功能支持:金仓数据库支持多种类型的索引、事务、存储过程等,能够满足不同行业和业务的数据库需求。
二、金仓数据库在线体验平台
金仓数据库在线体验平台的推出,旨在让用户能够更加便捷地接触和体验数据库的功能。尤其对于初学者和开发者而言,在线平台能够降低学习和使用的门槛。通过在线体验平台,用户可以快速尝试金仓数据库的各项功能,进行基础的数据库管理、查询优化、性能调优等操作。
“零门槛体验 + 多场景交互”,金仓数据库在线体验平台现已在金仓社区正式上线!通过精简功能模块和贴心场景引导,助力数据库使用者、开发者、架构师及DBA快速上手核心操作,无论是技术预研还是选型验证都能轻松搞定!
平台独创Oracle/PostgreSQL/MySQL/SQL Server四模合一环境,开启体验之前可以自由选择数据库模式。
实现四大主流数据库95%以上核心特性兼容,例如:
- MySQL模式:支持AUTO_INCREMENT、LIMIT分页、ON DUPLICATE KEY UPDATE等。
- Oracle模式:原生运行ROWNUM分页、DECODE()函数及PL/SQL块。
- SQL Server模式:兼容T-SQL流程控制(如IF...ELSE)及全局临时表(##前缀)。
- 系统视图:如MySQL模式下支持information_schema.tables视图,结构与原库一致。
平台有介绍模式常见的使用方式:
我们尝试创建表:
创建表customers客户表
- CREATE TABLE customers (
- C_ID INT AUTO_INCREMENT PRIMARY KEY,
- C_NAME VARCHAR(50) NOT NULL,
- C_ADDRESS TEXT NOT NULL,
- C_PHONE VARCHAR(15) NOT NULL
- );
复制代码
创建分区表items商品表
- CREATE TABLE items (
- I_ID INT PRIMARY KEY,
- I_NAME VARCHAR(100) NOT NULL,
- I_PRICE DECIMAL(10,2) NOT NULL,
- I_STOCK INT NOT NULL
- )
- PARTITION BY RANGE (I_PRICE)
- (
- PARTITION p_low VALUES LESS THAN (200),
- PARTITION p_medium VALUES LESS THAN (500),
- PARTITION p_high VALUES LESS THAN (1000),
- PARTITION p_high_price VALUES LESS THAN (MAXVALUE)
- );
复制代码
创建orders订单表表
- CREATE TABLE orders (
- O_ID INT ,
- O_DATE DATE NOT NULL,
- C_ID INT NOT NULL,
- I_ID INT NOT NULL,
- O_QUANTITY INT NOT NULL,
- O_TOTAL_PRICE DECIMAL(10,2) NOT NULL,
- FOREIGN KEY (C_ID) REFERENCES customers(C_ID),
- FOREIGN KEY (I_ID) REFERENCES items(I_ID)
- );
复制代码
现在向里面插入数据
使用INSERT 命令用于向表中插入数据。示例向customers表中插入数据:
- INSERT INTO customers (C_NAME, C_ADDRESS, C_PHONE) VALUES
- ('Alice Smith', '123 Main St, City A', '123-456-7890'),
- ('Bob Johnson', '456 Oak Ave, City B', '234-567-8901'),
- ('Charlie Brown', '789 Pine Rd, City C', '345-678-9012'),
- ('Diana White', '321 Elm St, City D', '456-789-0123'),
- ('Edward Green', '654 Birch Dr, City E', '567-890-1234'),
- ('Frances Hill', '987 Maple Ln, City F', '678-901-2345'),
- ('George Wright', '432 Cedar Rd, City G', '789-012-3456'),
- ('Helen King', '135 Willow St, City H', '890-123-4567'),
- ('Ian Miller', '246 Oak Dr, City I', '901-234-5678'),
- ('Judy Davis', '368 Pine Ave, City J', '012-345-6789');
复制代码
查看
查看customers客户表信息
kingbaseES使用 create index 语句来创建普通b-tree索引。
在customers表的c_name列上创建索引。
- create index indx_c_name on customers(c_name);
复制代码
使用create unique index语句在orders表中为o_id列创建唯一索引。
- select * from pg_indexes where schemaname='public';
复制代码
查询是从一个或多个表或视图中检索数据的操作。顶级SELECT语句称为查询,嵌套在另一个SQL语句中的查询称为子查询。本节描述一些查询与子查询类型以及如何使用它们。
SELECT 命令的一般语法是:
- [WITH with_queries] SELECT select_list FROM table_expression [sort_specification]
复制代码
视图是一个或多个表的逻辑表示形式。与表不同,视图既不分配存储空间,也不包含数据,而是通过定义的一个查询,从它所引用的基表中提取或派生出数据。视图的数据来自它所依赖基表,基表可以是表或其他视图。在视图上执行的所有操作实际上都指向基表。
通过create view命令来进行创建视图,示例如下
功能:按日期汇总订单金额和数量。
- CREATE OR REPLACE VIEW sales_summary AS
- SELECT
- DATE(o.O_DATE) AS order_date,
- COUNT(o.O_ID) AS order_count,
- SUM(o.O_TOTAL_PRICE) AS total_sales
- FROM orders o
- GROUP BY DATE(o.O_DATE);
复制代码
功能:监控库存量低于 10 的商品。
- CREATE OR REPLACE VIEW low_stock_items AS
- SELECT
- i.I_ID,
- i.I_NAME,
- i.I_STOCK
- FROM items i
- WHERE i.I_STOCK < 60;
复制代码
SQL函数在KingbaseES数据库中作为内置组件存在,适用于多种SQL语句,需注意区分于由PL/SQL编写的用户自定义函数。
调用这些SQL函数时,若参数类型不符,KingbaseES会自动将其转换为函数所需的数据类型,确保执行无碍。
示例
计算订单的折扣金额。
- CREATE OR REPLACE FUNCTION calculate_discount_amount(_o_id INT)
- RETURNS DECIMAL(8,2) AS $$
- DECLARE
- total_price DECIMAL(8,2);
- BEGIN
- -- 从 orders 表中获取订单的总价
- SELECT O_TOTAL_PRICE INTO total_price
- FROM orders
- WHERE O_ID = _o_id;
-
- -- 假设折扣率为 10%
- RETURN total_price * 0.10;
- END$$
- LANGUAGE plpgsql;
复制代码
触发器通过在数据操作时自动执行任务,强化了数据完整性和系统的自动化能力。合理设计和使用触发器,可以提升应用的效率、可靠性和安全性,但在开发和维护过程中需综合考虑性能影响和复杂性问题。
下面已一个简单示例来说明。
创建触发器
示例
功能:每当插入一条新订单时,触发器会从商品表中减去相应数量的商品库存。
- CREATE TRIGGER update_stock_AFTER_INSERT
- AFTER INSERT ON orders
- FOR EACH ROW
- BEGIN
- UPDATE items
- SET I_STOCK = I_STOCK - NEW.O_QUANTITY
- WHERE I_ID = NEW.I_ID;
- END;
复制代码
平台采用新手友好设计,提供场景化引导教学, 大大降低学习成本。用户可跟随向导任务,从零开始创建模式、表、函数、触发器等,快速熟悉金仓数据库的各项操作。
平台采用实时交互模式,用户在选定兼容模式后可直接输入SQL语句,系统自动检测语法并即时输出执行结果。
1. 创建数据库
- -- 创建一个新的数据库
- CREATE DATABASE my_database;
复制代码
2.连接数据库
连接到刚刚创建的数据库 my_database。
- -- 连接到指定数据库
- \c my_database;
复制代码
3.创建表
- -- 创建一个表用于存储员工信息
- CREATE TABLE employees (
- id SERIAL PRIMARY KEY, -- 自动生成唯一ID
- first_name VARCHAR(50), -- 员工的名字
- last_name VARCHAR(50), -- 员工的姓
- birth_date DATE, -- 员工的出生日期
- hire_date DATE, -- 员工的入职日期
- salary DECIMAL(10, 2), -- 员工的薪水,保留两位小数
- department VARCHAR(50) -- 员工所属的部门
- );
复制代码
4. 插入数据
- -- 向 employees 表中插入数据
- INSERT INTO employees (first_name, last_name, birth_date, hire_date, salary, department)
- VALUES
- ('John', 'Doe', '1990-01-15', '2015-06-01', 55000.00, 'Engineering'),
- ('Jane', 'Smith', '1985-03-22', '2012-04-12', 60000.00, 'Marketing'),
- ('Emily', 'Johnson', '1992-11-30', '2018-01-10', 45000.00, 'Human Resources');
复制代码
5. 查询数据
- -- 查询所有员工信息
- SELECT * FROM employees;
- -- 查询所有员工的姓名和薪水
- SELECT first_name, last_name, salary FROM employees;
- -- 查询薪水大于50000的员工
- SELECT * FROM employees
- WHERE salary > 50000;
复制代码
6. 更新数据
- -- 更新员工薪水
- UPDATE employees
- SET salary = salary + 5000
- WHERE department = 'Engineering';
- -- 更新员工的部门
- UPDATE employees
- SET department = 'Sales'
- WHERE first_name = 'Emily' AND last_name = 'Johnson';
复制代码
7. 删除数据
- -- 删除部门为 Sales 的所有员工
- DELETE FROM employees
- WHERE department = 'Sales';
- -- 删除所有薪水低于 50000 的员工
- DELETE FROM employees
- WHERE salary < 50000;
复制代码
8. 添加列
- -- 在 employees 表中添加一个新列用于存储员工的电子邮件
- ALTER TABLE employees
- ADD COLUMN email VARCHAR(100);
复制代码
9. 删除表
- -- 删除整个表(慎用,删除后无法恢复)
- DROP TABLE employees;
复制代码
10. 创建索引
- -- 创建一个索引,以便快速查询员工的姓氏
- CREATE INDEX idx_last_name ON employees (last_name);
复制代码
11. 事务处理
在金仓数据库中,可以使用事务来确保多个 SQL 操作的原子性和一致性。
- -- 开始事务
- BEGIN;
- -- 插入新员工数据
- INSERT INTO employees (first_name, last_name, birth_date, hire_date, salary, department)
- VALUES ('Michael', 'Brown', '1988-07-25', '2020-02-10', 70000.00, 'Sales');
- -- 更新现有员工的薪水
- UPDATE employees
- SET salary = 65000.00
- WHERE first_name = 'John' AND last_name = 'Doe';
- -- 如果没有错误,提交事务
- COMMIT;
- -- 如果发生错误,回滚事务
- -- ROLLBACK;
复制代码
12. 多表联接查询
- -- 假设我们有一个 departments 表,用于存储部门信息
- CREATE TABLE departments (
- id SERIAL PRIMARY KEY,
- name VARCHAR(50) NOT NULL
- );
- -- 向 departments 表中插入数据
- INSERT INTO departments (name)
- VALUES ('Engineering'), ('Marketing'), ('Human Resources');
- -- 联接查询 employees 和 departments 表,获取员工及其所属部门的详细信息
- SELECT e.first_name, e.last_name, e.salary, d.name AS department_name
- FROM employees e
- JOIN departments d ON e.department = d.name;
复制代码
13. 子查询
- -- 查询薪水高于公司平均薪水的员工
- SELECT first_name, last_name, salary
- FROM employees
- WHERE salary > (SELECT AVG(salary) FROM employees);
复制代码
14. 视图(View)
- -- 创建一个视图,用于查询所有薪水大于50000的员工信息
- CREATE VIEW high_salary_employees AS
- SELECT first_name, last_name, salary
- FROM employees
- WHERE salary > 50000;
- -- 查询视图中的数据
- SELECT * FROM high_salary_employees;
复制代码
15. 备份与恢复
金仓数据库支持数据备份与恢复,通过 pg_dump 和 pg_restore 工具可以方便地进行备份与恢复操作。
- pg_dump -U username -F c -b -v -f /path/to/backup_file.backup my_database
复制代码- pg_restore -U username -d my_database -v /path/to/backup_file.backup
复制代码
16. 使用 JSON 数据类型
金仓数据库支持 JSON 类型,可以用于存储和查询半结构化的数据。
- -- 创建一个包含 JSON 字段的表
- CREATE TABLE products (
- id SERIAL PRIMARY KEY,
- name VARCHAR(100),
- details JSONB -- JSONB 类型,用于存储 JSON 数据
- );
- -- 插入包含 JSON 数据的记录
- INSERT INTO products (name, details)
- VALUES
- ('Laptop', '{"brand": "Dell", "processor": "Intel i7", "ram": "16GB"}'),
- ('Smartphone', '{"brand": "Apple", "model": "iPhone 12", "storage": "128GB"}');
- -- 查询 JSON 数据
- SELECT name, details->>'brand' AS brand
- FROM products
- WHERE details->>'ram' = '16GB';
复制代码
17. 使用窗口函数
窗口函数允许对查询结果进行复杂的分析,通常用于计算排名、聚合等。
- -- 为每个员工计算其薪水在同一部门内的排名
- SELECT first_name, last_name, department, salary,
- RANK() OVER (PARTITION BY department ORDER BY salary DESC) AS salary_rank
- FROM employees;
复制代码
18. 创建触发器
触发器可以在特定事件(如插入、更新、删除)发生时自动执行指定的操作。
- -- 创建一个触发器,在插入新员工时记录其加入时间
- CREATE OR REPLACE FUNCTION log_employee_insert()
- RETURNS TRIGGER AS $$
- BEGIN
- INSERT INTO employee_logs (employee_id, action, action_time)
- VALUES (NEW.id, 'INSERT', NOW());
- RETURN NEW;
- END;
- $$ LANGUAGE plpgsql;
- -- 创建触发器,触发函数在插入员工时执行
- CREATE TRIGGER employee_insert_trigger
- AFTER INSERT ON employees
- FOR EACH ROW
- EXECUTE FUNCTION log_employee_insert();
复制代码
总的来说,金仓数据库在线体验平台是一个非常有价值的工具,它能够帮助用户更好地理解和使用金仓数据库,在实际应用中提升数据管理的效率和质量。无论是个人用户还是企业用户,都可以通过这个平台获得丰富的实践经验,进一步挖掘金仓数据库的潜力。
三、金仓数据库的技术架构
1. 金仓数据库的核心架构
金仓数据库的架构设计注重性能和可扩展性,特别适用于大规模数据处理和高并发场景。其主要组成部分包括:
-
分布式架构:金仓数据库支持多节点分布式部署,可以横向扩展处理能力。每个节点可处理独立的任务,且通过一致性协议进行同步,确保数据的高可用性和一致性。
-
高可用性与容错机制:金仓数据库实现了自动故障切换和数据冗余备份机制,能够在系统故障或硬件故障时快速恢复,并保持数据的完整性和一致性。
-
智能查询优化器:金仓数据库配备了智能查询优化器,能够自动选择最佳执行计划,从而大大提升查询性能,尤其是在复杂查询或大数据量操作时,展现出较强的优势。
2. 金仓数据库的事务与并发控制
金仓数据库采用了多版本并发控制(MVCC)机制,以确保在高并发环境下的数据一致性与隔离性。每个事务都有独立的视图,不会直接干扰其他事务的操作,极大地提升了事务的并发处理能力。
四、金仓数据库在线体验平台的优势
1. 零门槛使用体验
金仓数据库在线体验平台的最大优势在于它的零门槛特性。用户无需安装数据库软件或配置环境,只需注册账户并登录,即可体验金仓数据库的功能。对于初学者和非技术人员而言,这是一个非常便捷的工具,能够在短时间内上手数据库的基本操作。
2. 全面的操作功能
在线平台提供了与本地部署一致的数据库功能,包括数据库创建、表结构设计、数据导入导出、查询执行、事务管理等常见操作。用户不仅可以使用 SQL 语句进行数据操作,还可以通过图形化界面快速创建和管理数据库对象。
3. 实践案例与学习资源
平台提供了丰富的实践案例,用户可以按照案例进行实际操作,深入了解金仓数据库的应用场景与优化技巧。平台还提供了详细的文档和技术支持,帮助用户解决使用过程中遇到的问题。
4. 实时性能监控
金仓数据库在线平台提供了实时的性能监控功能,用户可以查看数据库实例的运行状态,包括 CPU 使用率、内存使用、查询响应时间等性能指标。这个功能对于开发者和运维人员来说尤为重要,能够帮助他们实时监控数据库的运行状态,确保系统的高效性。
五、金仓数据库的实际应用案例
1. 金融行业的应用
金仓数据库被广泛应用于金融行业,尤其是在银行、证券、保险等领域。其高可用性、数据安全性和高并发处理能力,完美契合金融行业对数据管理的需求。例如,某银行采用金仓数据库构建了其交易系统,能够实时处理数百万笔交易,且在高并发场景下依然保持稳定。
2. 电信行业的应用
电信行业通常需要处理大量的用户数据和实时通讯数据。金仓数据库支持大规模数据的高效存储和查询,成为电信公司首选的数据库解决方案。通过金仓数据库,电信公司能够高效地管理用户账户、通话记录、短信数据等。
3. 政府行业的应用
政府部门需要管理大量的公共事务数据,如人事信息、税务信息、社保信息等。金仓数据库凭借其数据安全性和扩展性,成为政府信息化建设的关键组成部分。通过金仓数据库,政府能够提高数据管理效率,保障数据安全。
|