X DevAPI 用户指南  / 第 2 章连接和会话概念  / 2.2 连接到会话  /  2.2.1 连接到单个 MySQL 服务器

2.2.1 连接到单个 MySQL 服务器

user在此示例中,使用 MySQL 用户帐户及其密码 建立与在默认 TCP/IP 端口 33060 上运行 X 插件的本地 MySQL 服务器实例的连接 。由于没有设置其他参数,因此使用默认值。

MySQL 外壳 JavaScript 代码

// Passing the parameters in the { param: value } format
var dictSession = mysqlx.getSession( {
        host: 'localhost', 'port': 33060,
        user: 'user', password: 'password' } )

var db1 = dictSession.getSchema('test')

// Passing the parameters in the URI format
var uriSession = mysqlx.getSession('user:password@localhost:33060')

var db2 = uriSession.getSchema('test')

MySQL 外壳 Python 代码

# Passing the parameters in the { param: value } format
dictSession = mysqlx.get_session( {
        'host': 'localhost', 'port': 33060,
        'user': 'user', 'password': 'password' } )

db1 = dictSession.get_schema('test')

# Passing the parameters in the URI format
uriSession = mysqlx.get_session('user:password@localhost:33060')

db2 = uriSession.get_schema('test')

以下示例显示如何通过提供 TCP/IP 地址“ localhost和与之前相同的用户帐户 连接到单个 MySQL 服务器实例 。在这种情况下,系统会提示您输入用户名和密码。

MySQL 外壳 JavaScript 代码

// Passing the parameters in the { param: value } format
// Query the user for the account information
print("Please enter the database user information.");
var usr = shell.prompt("Username: ", {defaultValue: "user"});
var pwd = shell.prompt("Password: ", {type: "password"});

// Connect to MySQL Server on a network machine
mySession = mysqlx.getSession( {
        host: 'localhost', 'port': 33060,
        user: usr, password: pwd} );

myDb = mySession.getSchema('test');

MySQL 外壳 Python 代码

# Passing the parameters in the { param: value } format
# Query the user for the account information
print("Please enter the database user information.")
usr = shell.prompt("Username: ", {'defaultValue': "user"})
pwd = shell.prompt("Password: ", {'type': "password"})

# Connect to MySQL Server on a network machine
mySession = mysqlx.get_session( {
        'host': 'localhost', 'port': 33060,
        'user': usr, 'password': pwd} )

myDb = mySession.get_schema('test')

Node.js JavaScript 代码

// Passing the parameters in the { param: value } format
mysqlx.getSession({ host: 'localhost', port: 33060, user: 'user', password: 'password' })
  .then(function (dictSession) {
    var db1 = dictSession.getSchema('test')
  })
// Passing the parameters in the URI format
mysqlx.getSession('user:password@localhost:33060')
  .then(function (uriSession) {
    var db2 = uriSession.getSchema('test')
  })

C#代码

// Query the user for the user information
Console.WriteLine("Please enter the database user information.");
Console.Write("Username: ");
var usr = Console.ReadLine();
Console.Write("Password: ");
var pwd = Console.ReadLine();
         
// Connect to server on localhost using a connection URI
var mySession = MySQLX.GetSession(string.Format("mysqlx://localhost:33060/test?user={0}&password={1}", usr, pwd));

var myDb = mySession.GetSchema("test");

Python代码

# Passing the parameters in the { param: value } format
dict_session = mysqlx.get_session({
    'host': 'localhost', 'port': 33060,
    'user': 'user', 'password': 'password'
})

my_schema_1 = dict_session.get_schema('test')

# Passing the parameters in the URI format
uri_session = mysqlx.get_session('user:password@localhost:33060')

my_schema_2 = uri_session.get_schema('test')

Java代码

import com.mysql.cj.xdevapi.*;

// Connect to server on localhost using a connection URI
Session mySession = new SessionFactory().getSession("mysqlx://localhost:33060/test?user=user&password=password");

Schema myDb = mySession.getSchema("test");

C++代码

// This code sample assumes that we have function prompt() defined somewhere.

string usr = prompt("Username:");
string pwd = prompt("Password:");

// Connect to MySQL Server on a network machine
Session mySession(SessionOption::HOST, "localhost",
                  SessionOption::PORT, 33060,
                  SessionOption::USER, usr,
                  SessionOption::PWD, pwd);

// An alternative way of defining session settings.

SessionSettings settings(SessionOption::HOST,"localhost",
                         SessionOption::PORT, 33060);

settings.set(SessionOption::USER, usr);
settings.set(SessionOption::PWD, pwd);

Session mySession(settings);

Schema myDb= mySession.getSchema("test");