连接mysql数据库代码
连接MySQL数据库通常需要使用编程语言提供的相应库或模块。
Python:
pythonimport mysql.connector
# 建立连接
connection = mysql.connector.connect(
host="your_host",
user="your_user",
password="your_password",
database="your_database"
)
# 创建游标
cursor = connection.cursor()
# 执行SQL查询
cursor.execute("SELECT * FROM your_table")
# 获取查询结果
result = cursor.fetchall()
# 关闭连接
cursor.close()
connection.close()
Java:
javaimport java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class MySQLExample {
public static void main(String[] args) {
try {
// 加载驱动程序
Class.forName("com.mysql.cj.jdbc.Driver");
// 建立连接
String url = "jdbc:mysql://your_host:3306/your_database";
String user = "your_user";
String password = "your_password";
Connection connection = DriverManager.getConnection(url, user, password);
// 创建语句对象
Statement statement = connection.createStatement();
// 执行SQL查询
ResultSet resultSet = statement.executeQuery("SELECT * FROM your_table");
// 处理查询结果
while (resultSet.next()) {
// 处理每一行数据
}
// 关闭连接
resultSet.close();
statement.close();
connection.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
PHP:
php<?php
$host = "your_host";
$user = "your_user";
$password = "your_password";
$database = "your_database";
// 建立连接
$connection = new mysqli($host, $user, $password, $database);
// 检查连接是否成功
if ($connection->connect_error) {
die("Connection failed: " . $connection->connect_error);
}
// 执行SQL查询
$query = "SELECT * FROM your_table";
$result = $connection->query($query);
// 处理查询结果
while ($row = $result->fetch_assoc()) {
// 处理每一行数据
}
// 关闭连接
$result->close();
$connection->close();
?>
请注意替换代码中的"your_host"、"your_user"、"your_password"、"your_database"和"your_table"等部分为你自己的数据库连接信息。
Node.js:
javascriptconst mysql = require('mysql2');
// 创建连接池
const pool = mysql.createPool({
host: 'your_host',
user: 'your_user',
password: 'your_password',
database: 'your_database',
waitForConnections: true,
connectionLimit: 10,
queueLimit: 0
});
// 从连接池中获取连接
pool.getConnection((err, connection) => {
if (err) {
console.error('Error connecting to MySQL:', err);
return;
}
// 执行查询
connection.query('SELECT * FROM your_table', (error, results, fields) => {
// 处理查询结果
if (error) throw error;
// 处理每一行数据
results.forEach(row => {
// 处理每一行数据
});
// 释放连接
connection.release();
});
});
// 关闭连接池
pool.end();
请确保在使用这些代码之前,你已经安装了相应的数据库驱动或模块,例如对于 Node.js,你可以通过
bashnpm install mysql2
在上述代码中,也需要将"your_host"、"your_user"、"your_password"、"your_database"和"your_table"等部分替换为你实际的数据库连接信息。