插入文档 #

INSERT INTO <class> [(<field>[,<field>]*)] 
VALUES (<value>[,<value>]*)[, (<value>[,<value>]*)]*

INSERT INTO <class> SET <field> = <value>[, <field> = <value>]*

INSERT特点：
├── 创建新的文档记录
├── 自动生成Record ID
├── 支持批量插入
├── 支持JSON格式
└── 返回插入的记录

INSERT INTO Person (name, age, city) VALUES ('Tom', 30, 'Beijing')

INSERT INTO Person SET name = 'Tom', age = 30, city = 'Beijing'

INSERT INTO Person CONTENT {'name': 'Tom', 'age': 30, 'city': 'Beijing'}

INSERT INTO Person SET name = 'Tom', age = 30 RETURN @rid, name, age
INSERT INTO Person SET name = 'Tom', age = 30 RETURN @this

INSERT INTO CLUSTER:person_east (name, age) VALUES ('Tom', 30)

INSERT INTO Person SET 
    name = 'Tom',
    age = 30,
    salary = 5000.50,
    isActive = true,
    birthDate = DATE('1994-01-15'),
    createdAt = DATETIME('2024-01-15 10:30:00')

INSERT INTO Person SET 
    name = 'Tom',
    hobbies = ['reading', 'coding', 'gaming'],
    tags = {'developer', 'java', 'python'},
    preferences = {'theme': 'dark', 'language': 'en'}

INSERT INTO Person SET 
    name = 'Tom',
    address = {
        'street': 'Main Street',
        'city': 'Beijing',
        'zipCode': '100000'
    }

INSERT INTO Company SET name = 'ABC Corp'

INSERT INTO Person SET 
    name = 'Tom',
    employer = (SELECT FROM Company WHERE name = 'ABC Corp')

INSERT INTO Person SET 
    name = 'Tom',
    friends = (SELECT FROM Person WHERE name IN ['Jerry', 'Mike'])

INSERT INTO Person (name, age, city) VALUES 
    ('Tom', 30, 'Beijing'),
    ('Jerry', 25, 'Shanghai'),
    ('Mike', 35, 'Guangzhou')

LET persons = [
    {'name': 'Tom', 'age': 30},
    {'name': 'Jerry', 'age': 25},
    {'name': 'Mike', 'age': 35}
]
INSERT INTO Person SET name = $persons.name, age = $persons.age
UNWIND $persons

INSERT INTO PersonBackup SET name = p.name, age = p.age 
FROM (SELECT FROM Person WHERE status = 'active') p

INSERT INTO PersonArchive FROM SELECT FROM Person WHERE createdAt < DATE('2023-01-01')

IF (SELECT COUNT(*) FROM Person WHERE email = 'tom@example.com' = 0) {
    INSERT INTO Person SET name = 'Tom', email = 'tom@example.com'
}

UPDATE Person SET name = 'Tom' 
UPSERT 
WHERE email = 'tom@example.com'

LET existing = SELECT FROM Person WHERE email = 'tom@example.com';
IF ($existing.size() = 0) {
    INSERT INTO Person SET name = 'Tom', email = 'tom@example.com'
}

CREATE CLASS Person EXTENDS V
INSERT INTO Person SET name = 'Tom', age = 30

CREATE VERTEX Person SET name = 'Tom', age = 30

CREATE CLASS KNOWS EXTENDS E
INSERT INTO KNOWS FROM (SELECT FROM Person WHERE name = 'Tom') 
TO (SELECT FROM Person WHERE name = 'Jerry')
SET since = 2020

CREATE EDGE KNOWS FROM (SELECT FROM Person WHERE name = 'Tom') 
TO (SELECT FROM Person WHERE name = 'Jerry')
SET since = 2020

CREATE EDGE WORKS_AT FROM (SELECT FROM Person WHERE employer IS NULL) 
TO (SELECT FROM Company WHERE name = 'ABC Corp')

INSERT INTO Person FROM CSV '/data/persons.csv' 
WITH HEADERS 
SET name = string(name), age = integer(age)

LET data = SELECT FROM JSON:'/data/persons.json'
INSERT INTO Person FROM $data

{
    "source": {"file": {"path": "/data/persons.json"}},
    "extractor": {"json": {}},
    "transformers": [
        {"vertex": {"class": "Person"}}
    ],
    "loader": {
        "orientdb": {
            "dbURL": "plocal:/data/databases/mydb",
            "classes": [{"name": "Person"}]
        }
    }
}

INSERT INTO Person SET 
    name = 'Tom',
    createdAt = sysdate(),
    uuid = uuid(),
    hash = hash('MD5', 'Tom')

INSERT INTO Person SET 
    name = 'Tom',
    code = generateCode('P', 6)

INSERT INTO Person SET name = 'Tom', age = 30 RETURN @rid, @version

LET existing = SELECT FROM Person WHERE email = 'tom@example.com';
IF ($existing.size() > 0) {
    SELECT 'Email already exists' AS error
} ELSE {
    INSERT INTO Person SET name = 'Tom', email = 'tom@example.com' RETURN @rid
}

BEGIN
INSERT INTO Person SET name = 'Tom', age = 30
LET p = SELECT FROM Person WHERE name = 'Tom'
INSERT INTO AuditLog SET action = 'INSERT', recordId = $p[0].@rid, timestamp = sysdate()
COMMIT

LET batch = [
    {'name': 'Person1', 'age': 20},
    {'name': 'Person2', 'age': 25},
    {'name': 'Person3', 'age': 30}
]
BEGIN
FOREACH ($item IN $batch) {
    INSERT INTO Person SET name = $item.name, age = $item.age
}
COMMIT

BEGIN
INSERT INTO Person SET name = 'Tom'
INSERT INTO Person SET name = 'Jerry'
INSERT INTO Person SET name = 'Mike'
COMMIT

ALTER INDEX Person.name DISABLE
INSERT INTO Person SET name = 'Tom', age = 30
ALTER INDEX Person.name ENABLE

常见错误：
├── 违反唯一约束
├── 违反NOTNULL约束
├── 违反MANDATORY约束
├── 类型不匹配
└── 违反范围约束

TRY {
    INSERT INTO Person SET name = 'Tom', email = 'tom@example.com'
} CATCH {
    SELECT 'Insert failed: ' + $error AS message
}

INSERT INTO User SET 
    id = uuid(),
    username = 'tom_hanks',
    email = 'tom@example.com',
    password = hash('SHA-256', 'password123'),
    status = 'active',
    roles = ['user'],
    createdAt = sysdate(),
    updatedAt = sysdate()
RETURN @rid, id, username

BEGIN
LET user = SELECT FROM User WHERE id = 'user_001';
LET order = INSERT INTO Order SET 
    id = uuid(),
    userId = $user[0].@rid,
    status = 'pending',
    totalAmount = 0,
    createdAt = sysdate()
RETURN @rid;
COMMIT
RETURN $order

INSERT INTO Log SET 
    level = 'INFO',
    message = 'User logged in',
    userId = (SELECT FROM User WHERE username = 'tom'),
    ip = '192.168.1.1',
    timestamp = sysdate()

LET data = [
    {'name': 'Product1', 'price': 100, 'stock': 50},
    {'name': 'Product2', 'price': 200, 'stock': 30},
    {'name': 'Product3', 'price': 150, 'stock': 80}
]
BEGIN
FOREACH ($item IN $data) {
    INSERT INTO Product SET 
        name = $item.name,
        price = $item.price,
        stock = $item.stock,
        createdAt = sysdate()
}
COMMIT