连接mysql数据库代码

连接MySQL数据库通常需要使用编程语言提供的相应库或模块。

Python:

python
import 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:

java
import 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:

javascript
const 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,你可以通过

bash
npm install mysql2

在上述代码中,也需要将"your_host"、"your_user"、"your_password"、"your_database"和"your_table"等部分替换为你实际的数据库连接信息。

标签