如何用java创建一个jdbc程序

如何用java创建一个jdbc程序,第1张

public class MysqlDemo {

    public static void main(String[] args) throws Exception {

        Connection conn = null

        String sql

        // MySQL的JDBC URL编写方式:jdbc:mysql://主机名称:连接端口/数据库的名称?参数=值

        // 避免中文乱码要指定useUnicode和characterEncoding

        // 执行数据库 *** 作之前要在数据库管理系统上创建一个数据库,名字自己定,

        // 下面语句之前就要先创建javademo数据库

        String url = "jdbc:mysql://localhost:3306/javademo?"

                + "user=root&password=root&useUnicode=true&characterEncoding=UTF8"

 

        try {

            // 之所以要使用下面这条语句,是因为要使用MySQL的驱动,所以我们要把它驱动起来,

            // 可以通过Class.forName把它加载进去,也可以通过初始化来驱动起来,下面三种形式都可以

            Class.forName("com.mysql.jdbc.Driver")// 动态加载mysql驱动

            // or:

            // com.mysql.jdbc.Driver driver = new com.mysql.jdbc.Driver()

            // or:

            // new com.mysql.jdbc.Driver()

 

            System.out.println("成功加载MySQL驱动程序")

            // 一个Connection代表一个数据库连接

            conn = DriverManager.getConnection(url)

            // Statement里面带有很多方法,比如executeUpdate可以实现插入,更新和删除猜大等

            Statement stmt = conn.createStatement()

            sql = "create table student(NO char(20),name varchar(20),primary key(NO))"

            int result = stmt.executeUpdate(sql)// executeUpdate语句会返回一个受影响的行数,如果返回-1就没有成功

            if (result != -1) {

                System.out.println("创建数据表成功")

                sql = "insert into student(NO,name) values('2012001','陶伟基')"

                result = stmt.executeUpdate(sql)

                sql = "insert into student(NO,name) values('2012002','周小俊')"

                result = stmt.executeUpdate(sql)

                sql = "select * from student"

                ResultSet rs = stmt.executeQuery(sql)// executeQuery会返回结果的集合,否则返回空值

                System.out.println("学号\t姓名")

                while (rs.next()) {

             返兆缺       System.out

             漏辩               .println(rs.getString(1) + "\t" + rs.getString(2))// 入如果返回的是int类型可以用getInt()

                }

            }

        } catch (SQLException e) {

            System.out.println("MySQL *** 作错误")

            e.printStackTrace()

        } catch (Exception e) {

            e.printStackTrace()

        } finally {

            conn.close()

        }

 

    }

 

}

这里适配的是MySQL,如果是其他数据里,url要对应调整

用到的是mysql的jar包,需要自己导入,这咐含扒里我是用的是5.1.48.可以选择大于这个版本的

import java.sql.*

public class EditInfo {

public static void main(String[] args) throws Exception {

//加载驱动

Class.forName("com.mysql.jdbc.Driver")

//获取连接

Connection conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/jdbctest?user=root&password=123456&useUnicode=true&characterEncoding=UTF-8")

//创衡昌建preparestatement

PreparedStatement pstm=conn.prepareStatement("insert into students values(?,?,?,?)")

pstm.setInt(1,1)

pstm.setString(2,"莉莉")

pstm.setString(3,"生产")

pstm.setString(4,"1班")

pstm.executeUpdate()

pstm.setInt(1,2)

pstm.setString(2,"毛毛")

pstm.setString(3,"制造")

pstm.setString(4,"2班"老空)

pstm.executeUpdate()

pstm.setInt(1,3)

pstm.setString(2,"妮妮")

pstm.setString(3,"资讯")

pstm.setString(4,"3班")

pstm.executeUpdate()

pstm.setInt(1,4)

pstm.setString(2,"菲菲")

pstm.setString(3,"售后")

pstm.setString(4,"4班")

pstm.executeUpdate()

pstm.setInt(1,5)

pstm.setString(2,"娜娜")

pstm.setString(3,"海外")

pstm.setString(4,"5班")

pstm.executeUpdate()

PreparedStatement query=conn.prepareStatement("select * from students")

ResultSet rs = query.executeQuery()

while (rs.next()) {

String result = rs.getInt(1) + " " + rs.getString(2) + " " + rs.getString(3) + " " + rs.getString(4)

System.out.println(result)

}

pstm.close()

query.close()

conn.close()

}

}

显示结果


欢迎分享,转载请注明来源:内存溢出

原文地址: https://outofmemory.cn/yw/12424379.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-05-25
下一篇 2023-05-25

发表评论

登录后才能评论

评论列表(0条)

保存