Mnesia数据库及其集群的配置
mnesia_manage.erl模块专门用以管理本工程中用到的各种数据库。 其导出函数有: create_all_tables/0,用以创建本模块里定义的所有数据表。 create_online_users/0,创建在线用户表。 create_users/0,创建用户表 create_user_data/0,创建用户资料表 create_ava
mnesia_manage.erl模块专门用以管理本工程中用到的各种数据库。
其导出函数有:
create_all_tables/0,用以创建本模块里定义的所有数据表。
create_online_users/0,创建在线用户表。
create_users/0,创建用户表
create_user_data/0,创建用户资料表
create_available_acc/0,创建可供注册的账号表
create_reserved_acc/0,创建保留账号表
insert_formal_acc/2插入正式的账号
insert_test_acc/2,插入测试账号
select_all/1,[Tab]选择某表所有记录
tab_length/1,[Tab]查询某标的长度
使用本模块时,执行erl命令时,除了要指明节点名称等,还需要指明存放mnesia数据库的路径,命令如下:
erl -sname NodeChatCore1 -pa ./chat_server/ebin -mnesia dir '"./mnesia_dir_ChatServerCore_1"'
进入erlang shell后,执行命令:mnesia_manage:create_all_tables(). 之后退出shell,进入mnesia_dir_ChatServerCore_1文件夹,即可看到刚刚建立的各个数据库的文件。
再次进入节点NodeChatCore1 的shell,让我们检查一下刚才建立的数据表是否正常。
从上图可以看到,想要建立的数据库都建立好了。现在,往available_acc数据表里插入100条示例账号:
提示信息说明100条数据插入成功。100012-100100的数据太长,截图太小无法完全显示出来。
我们测试一下,随意从刚刚插入的数据表里读取一条记录:
成功了!
现在,用相同的方法打开ChatServerExt模块的shell,不要建立该模块的数据库模式,而是从已经建立数据库模式的节点NodeChatCore1@localhost处拷贝数据库模式,我们看到,现在2个节点已经形成了一个集群。具体过程如下:
但除了schema,其他数据库都是运行在remote上的,也即远端的其他节点。而且,即使schema也只是运行在ram里的,无法持久化存储。现在,我们从现有节点处拷贝各数据库的配置文件:
再次查看,我们发现,我们需要的数据表已经运行在当前节点了,2个节点的数据库将保持同步和一致。
我们选择做个测试,在2个节点里执行相同的命令,可以看到,2个节点都能获得相同的数据了。

Hot AI Tools

Undresser.AI Undress
AI-powered app for creating realistic nude photos

AI Clothes Remover
Online AI tool for removing clothes from photos.

Undress AI Tool
Undress images for free

Clothoff.io
AI clothes remover

Video Face Swap
Swap faces in any video effortlessly with our completely free AI face swap tool!

Hot Article

Hot Tools

Notepad++7.3.1
Easy-to-use and free code editor

SublimeText3 Chinese version
Chinese version, very easy to use

Zend Studio 13.0.1
Powerful PHP integrated development environment

Dreamweaver CS6
Visual web development tools

SublimeText3 Mac version
God-level code editing software (SublimeText3)

Hot Topics











Apple's latest releases of iOS18, iPadOS18 and macOS Sequoia systems have added an important feature to the Photos application, designed to help users easily recover photos and videos lost or damaged due to various reasons. The new feature introduces an album called "Recovered" in the Tools section of the Photos app that will automatically appear when a user has pictures or videos on their device that are not part of their photo library. The emergence of the "Recovered" album provides a solution for photos and videos lost due to database corruption, the camera application not saving to the photo library correctly, or a third-party application managing the photo library. Users only need a few simple steps

How to use MySQLi to establish a database connection in PHP: Include MySQLi extension (require_once) Create connection function (functionconnect_to_db) Call connection function ($conn=connect_to_db()) Execute query ($result=$conn->query()) Close connection ( $conn->close())

To handle database connection errors in PHP, you can use the following steps: Use mysqli_connect_errno() to obtain the error code. Use mysqli_connect_error() to get the error message. By capturing and logging these error messages, database connection issues can be easily identified and resolved, ensuring the smooth running of your application.

Using the database callback function in Golang can achieve: executing custom code after the specified database operation is completed. Add custom behavior through separate functions without writing additional code. Callback functions are available for insert, update, delete, and query operations. You must use the sql.Exec, sql.QueryRow, or sql.Query function to use the callback function.

JSON data can be saved into a MySQL database by using the gjson library or the json.Unmarshal function. The gjson library provides convenience methods to parse JSON fields, and the json.Unmarshal function requires a target type pointer to unmarshal JSON data. Both methods require preparing SQL statements and performing insert operations to persist the data into the database.

Through the Go standard library database/sql package, you can connect to remote databases such as MySQL, PostgreSQL or SQLite: create a connection string containing database connection information. Use the sql.Open() function to open a database connection. Perform database operations such as SQL queries and insert operations. Use defer to close the database connection to release resources.

PHP database connection guide: MySQL: Install the MySQLi extension and create a connection (servername, username, password, dbname). PostgreSQL: Install the PgSQL extension and create a connection (host, dbname, user, password). Oracle: Install the OracleOCI8 extension and create a connection (servername, username, password). Practical case: Obtain MySQL data, PostgreSQL query, OracleOCI8 update record.

Use the DataAccessObjects (DAO) library in C++ to connect and operate the database, including establishing database connections, executing SQL queries, inserting new records and updating existing records. The specific steps are: 1. Include necessary library statements; 2. Open the database file; 3. Create a Recordset object to execute SQL queries or manipulate data; 4. Traverse the results or update records according to specific needs.
