Java使用JDBC连接MYSQL数据库增删改查示例

下面是编程之家 jb51.cc 通过网络收集整理的代码片段。

编程之家小编现在分享给大家，也给大家做个参考。

JDBC连接MysqL数据库：

import java.sql.Connection;
import java.sql.DriverManager;

public class MysqL {
    public static void main(String arg[]) {
        try {
            Connection con = null; //定义一个MysqL链接对象
            Class.forName("com.MysqL.jdbc.Driver").newInstance(); //MysqL驱动
            con = DriverManager.getConnection("jdbc:MysqL://127.0.0.1:3306/test","root","root"); //链接本地MysqL
            System.out.print("yes");
        } catch (Exception e) {
            System.out.print("MysqL ERROR:" + e.getMessage());
        }

    }
}

写入一条数据

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class MysqL {

    /**
     * 入口函数
     * @param arg
     */
    public static void main(String arg[]) {
        try {
            Connection con = null; //定义一个MysqL链接对象
            Class.forName("com.MysqL.jdbc.Driver").newInstance(); //MysqL驱动
            con = DriverManager.getConnection("jdbc:MysqL://127.0.0.1:3306/test","root"); //链接本地MysqL

            Statement stmt; //创建声明
            stmt = con.createStatement();

            //新增一条数据
            stmt.executeUpdate("INSERT INTO user (username,password) VALUES ('init','123456')");
            ResultSet res = stmt.executeQuery("select LAST_INSERT_ID()");
            int ret_id;
            if (res.next()) {
                ret_id = res.getInt(1);
                System.out.print(ret_id);
            }

        } catch (Exception e) {
            System.out.print("MysqL ERROR:" + e.getMessage());
        }

    }
}

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class MysqL {

    /**
     * 入口函数
     * @param arg
     */
    public static void main(String arg[]) {
        try {
            Connection con = null; //定义一个MysqL链接对象
            Class.forName("com.MysqL.jdbc.Driver").newInstance(); //MysqL驱动
            con = DriverManager.getConnection("jdbc:MysqL://127.0.0.1:3306/test",'123456')");
            ResultSet res = stmt.executeQuery("select LAST_INSERT_ID()");
            int ret_id;
            if (res.next()) {
                ret_id = res.getInt(1);
                System.out.print(ret_id);
            }

            //删除一条数据
            String sql = "DELETE FROM user WHERE id = 1";
            long deleteRes = stmt.executeUpdate(sql); //如果为0则没有进行删除操作，如果大于0，则记录删除的条数
            System.out.print("DELETE:" + deleteRes);

            //更新一条数据
            String updatesql = "UPDATE user SET username = 'xxxx' WHERE id = 2";
            long updateRes = stmt.executeUpdate(updatesql);
            System.out.print("UPDATE:" + updateRes);

        } catch (Exception e) {
            System.out.print("MysqL ERROR:" + e.getMessage());
        }

    }
}

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Statement;

public class MysqL {

    /**
     * 入口函数
     * @param arg
     */
    public static void main(String arg[]) {
        try {
            Connection con = null; //定义一个MysqL链接对象
            Class.forName("com.MysqL.jdbc.Driver").newInstance(); //MysqL驱动
            con = DriverManager.getConnection("jdbc:MysqL://127.0.0.1:3306/test",'123456')");
            ResultSet res = stmt.executeQuery("select LAST_INSERT_ID()");
            int ret_id;
            if (res.next()) {
                ret_id = res.getInt(1);
                System.out.print(ret_id);
            }

            //删除一条数据
            String sql = "DELETE FROM user WHERE id = 1";
            long deleteRes = stmt.executeUpdate(sql); //如果为0则没有进行删除操作，如果大于0，则记录删除的条数
            System.out.print("DELETE:" + deleteRes);

            //更新一条数据
            String updatesql = "UPDATE user SET username = 'xxxx' WHERE id = 2";
            long updateRes = stmt.executeUpdate(updatesql);
            System.out.print("UPDATE:" + updateRes);

            //查询数据并输出
            String selectsql = "SELECT * FROM user";
            ResultSet selectRes = stmt.executeQuery(selectsql);
            while (selectRes.next()) { //循环输出结果集
                String username = selectRes.getString("username");
                String password = selectRes.getString("password");
                System.out.print("\r\n\r\n");
                System.out.print("username:" + username + "password:" + password);
            }

        } catch (Exception e) {
            System.out.print("MysqL ERROR:" + e.getMessage());
        }

    }
}

• rs.absolute() //绝对位置，负数表示从后面数
• rs.first()第一条
• rs.last()最后一条
• rs.prevIoUst()前一条
• rs.next()后一条
• rs.beforeFirst()第一条之前
• rs.afterLast()最后之后
• rs.isFirst(),rs.isLast(),rs.isBeforeFirst(),rs.isAfterLast

以上是编程之家(jb51.cc)为你收集整理的全部代码内容，希望文章能够帮你解决所遇到的程序开发问题。

如果觉得编程之家网站内容还不错，欢迎将编程之家网站推荐给程序员好友。