feat(create): 创建

README.md

@@ -9,21 +9,38 @@ import { Client } from "../mod.ts";
 const client = new Client();
 await client.connect("http://localhost:9200/");
 
-const ajax = async () => {
+const count = async () => {
   try {
-    const count = await client.count({
+    const names = await client.count({
       index: "myindex2",
-      // method: "post",
+      method: "post",
     });
-    console.log(count);
+    console.log(names);
+  } catch (error) {
+    console.error(error);
+  }
+};
+
+const create = async () => {
+  try {
+    const names = await client.create({
+      index: "myindex2",
+      id: 3,
+      body: {
+        title: "当时明月在",
+        id: "6058046316761d2e8752aa4c",
+      },
+    });
+    console.log(names);
   } catch (error) {
     console.error(error);
   }
 };
 
 console.time("ajax");
 // await Array.from(new Array(100)).map(ajax);
-await ajax();
+await count();
+await create();
 console.timeEnd("ajax");
 
 ```

examples/conn.ts

@@ -1,16 +1,41 @@
 import { Client } from "../mod.ts";
+import { v4 } from "https://deno.land/[email protected]/uuid/mod.ts";
 
 const client = new Client();
-
 await client.connect("http://localhost:9200/");
 
-const ajax = async () => {
+const count = async () => {
   try {
     const names = await client.count({
       index: "myindex2",
       method: "post",
     });
+    console.log(names);
+  } catch (error) {
+    console.error(error);
+  }
+};
 
+const create = async () => {
+  try {
+    const id = v4.generate();
+    const names = await client.create({
+      index: "myindex2",
+      id,
+      body: {
+        deleted: false,
+        // _id: '6058046316761d2e8752aa4c44',
+        _name: "hahs",
+        title: "倚天屠龙记4",
+        content: "剑心通明4",
+        userId: "41",
+        isSecret: false,
+        group: "中国",
+        contentText: "剑心通明4",
+        titleText: "倚天屠龙记4",
+        id: "6058046316761d2e8752aa4c",
+      },
+    });
     console.log(names);
   } catch (error) {
     console.error(error);
@@ -19,5 +44,10 @@ const ajax = async () => {
 
 console.time("ajax");
 // await Array.from(new Array(100)).map(ajax);
-await ajax();
+// await create();
+await count();
+
+setTimeout(async () => {
+  await create();
+}, 1000);
 console.timeEnd("ajax");

src/client.ts

@@ -67,6 +67,35 @@ export class Client {
     });
   }
 
+  create(params: {
+    method?: Method;
+    body: any;
+    id: string | number;
+    index: string;
+  }) {
+    let {
+      method = "PUT",
+      body,
+      id,
+      index,
+    } = params;
+    let path = "";
+
+    if (index != null && id != null) {
+      const type = "_doc";
+      path = "/" + encodeURIComponent(index) + "/" + encodeURIComponent(type) +
+        "/" + encodeURIComponent(id) + "/" + "_create";
+    } else {
+      path = "/" + encodeURIComponent(index) + "/" + "_create" + "/" +
+        encodeURIComponent(id);
+    } // build request object
+    return ajax({
+      url: path,
+      method,
+      data: body,
+    });
+  }
+
   close() {
     if (this.conn) {
       this.conn.close();