Movatterモバイル変換

• Minimum Requirements

• Import the Document Store Sample

• Add References to Required DLLs

• Import Namespaces

• Create a Session

• Find a Row Within a Collection

• Insert a New Document into a Collection

• Update an Existing Document

• Delete a Specific Document

• Close the Session

• Complete Code Example

A MySQL script is provided with data and a JSON collection. The sample contains the following:

To install theworld_x database sample, follow these steps:

Create a new Visual Studio Console Project targeting .NET Framework 4.6.2 (or later), .NET Core 1.1, or .NET Core 2.0. The code examples in this tutorial are shown in the C# language, but you can use any .NET language.

Add a reference in your project to the following DLLs:

Import the required namespaces by adding the following statements:

using MySqlX.XDevAPI;using MySqlX.XDevAPI.Common;using MySqlX.XDevAPI.CRUD;

A session in the X DevAPI is a high-level database session concept that is different from working with traditional low-level MySQL connections. It is important to understand that this session is not the same as a traditional MySQL session. Sessions encapsulate one or more actual MySQL connections.

The following example opens a session, which you can use later to retrieve a schema and perform basic CRUD operations.

string schemaName = "world_x"; // Define the connection stringstring connectionURI = "mysqlx://test:test@localhost:33060";  Session session = MySQLX.GetSession(connectionURI);// Get the schema objectSchema schema = session.GetSchema(schemaName);

After the session is instantiated, you can execute a find operation. The next example uses the session object that you created:

// Use the collection 'countryinfo'var myCollection = schema.GetCollection("countryinfo");var docParams = new DbDoc(new { name1 = "Albania", _id1 = "ALB" });// Find a documentDocResult foundDocs = myCollection.Find("Name = :name1 || _id = :_id1").Bind(docParams).Execute();while (foundDocs.Next()){Console.WriteLine(foundDocs.Current["Name"]);Console.WriteLine(foundDocs.Current["_id"]);}

//Insert a new document with an identifiervar obj = new { _id = "UKN", Name = "Unknown" };Result r = myCollection.Add(obj).Execute();

// using the same docParams object previously createddocParams = new DbDoc(new { name1 = "Unknown", _id1 = "UKN" });r = myCollection.Modify("_id = :Id").Bind("id", "UKN").Set("GNP", "3308").Execute();if (r.AffectedItemsCount == 1){  foundDocs = myCollection.Find("Name = :name1|| _id = :_id1").Bind(docParams).Execute();  while (foundDocs.Next())  {     Console.WriteLine(foundDocs.Current["Name"]);     Console.WriteLine(foundDocs.Current["_id"]);     Console.WriteLine(foundDocs.Current["GNP"]);  }}

r = myCollection.Remove("_id = :id").Bind("id", "UKN").Execute();

session.Close();

The following example shows the basic operations that you can perform with a collection.

using MySqlX.XDevAPI;using MySqlX.XDevAPI.Common;using MySqlX.XDevAPI.CRUD;using System;namespace MySQLX_Tutorial{  class Program  {    static void Main(string[] args)    {       string schemaName = "world_x";      string connectionURI = "mysqlx://test:test@localhost:33060";        Session session = MySQLX.GetSession(connectionURI);      Schema schema = session.GetSchema(schemaName);       // Use the collection 'countryinfo'      var myCollection = schema.GetCollection("countryinfo");      var docParams = new DbDoc(new { name1 = "Albania", _id1 = "ALB" });       // Find a document      DocResult foundDocs = myCollection.Find("Name = :name1 || _id = :_id1").Bind(docParams).Execute();       while (foundDocs.Next())      {        Console.WriteLine(foundDocs.Current["Name"]);        Console.WriteLine(foundDocs.Current["_id"]);      }       //Insert a new document with an id      var obj = new { _id = "UKN", Name = "Unknown" };      Result r = myCollection.Add(obj).Execute();       //update an existing document      docParams = new DbDoc(new { name1 = "Unknown", _id1 = "UKN" });      r = myCollection.Modify("_id = :Id").Bind("id", "UKN").Set("GNP", "3308").Execute();      if (r.AffectedItemsCount == 1)      {        foundDocs = myCollection.Find("Name = :name1|| _id = :_id1").Bind(docParams).Execute();        while (foundDocs.Next())        {          Console.WriteLine(foundDocs.Current["Name"]);          Console.WriteLine(foundDocs.Current["_id"]);          Console.WriteLine(foundDocs.Current["GNP"]);        }      }       // delete a row in a document      r = myCollection.Remove("_id = :id").Bind("id", "UKN").Execute();           //close the session      session.Close();      Console.ReadKey();    }  }}