java怎么返回mysql协议

java怎么返回mysql协议,第1张

1 在开发环境中加载指定数据库的驱动程序。

接下来的实验中,使用数据库MySQL,所以需要下载MySQL支持JDBC的驱动程序(mysql-connector-java-5118-binjar)。

2 开发环境是MyEclipse,将下载得到的驱动程序加载进开发环境中。

3 在Java程序中加载驱动程序。

在Java程序中,通过 “ClassforName(“指定数据库的驱动程序”)”

方式来加载添加到开发环境中的驱动程序,例如ClassforName(“commysqljdbcDriver”)。

4 创建数据连接对象:通过DriverManager类创建数据库连接对象Connection。

DriverManager类作用于Java程序和JDBC驱动程序之间,用于检查所加载的驱动程序是否可以建立连接,然后通过它的getConnection方法,根据数据库的URL、用户名和密码,创建一个JDBC

Connection 对象。代码如:Connection connection = DriverManagergetConnection(“连接数据库的URL", "用户名",

"密码”)。

其中,URL=协议名+IP地址(域名)+端口+数据库名称;用户名和密码是指登录数据库时所使用的用户名和密码。具体示例创建MySQL的数据库连接代码如下:

Connection connectMySQL =

DriverManagergeiConnection(“jdbc:mysql://localhost:3306/myuser","root"

,"root" );

5 创建Statement对象:Statement 类的主要是用于执行静态 SQL

语句并返回它所生成结果的对象。

通过Connection 对象的 createStatement()方法可以创建一个Statement对象。例如:Statement statament =

connectioncreateStatement(); 具体示例创建Statement对象代码如下:Statement statamentMySQL =connectMySQLcreateStatement();

6 调用Statement对象的相关方法执行相对应的 SQL

语句:通过execuUpdate()方法用来数据的更新,包括插入和删除等 *** 作,例如向staff表中插入一条数据的代码:

statementexcuteUpdate( "INSERT INTO

staff(name, age, sex,address, depart, worklen,wage)" + " VALUES ('Tom1', 321,

'M', 'china','Personnel','3','3000' ) ") ;

7 通过调用Statement对象的executeQuery()方法进行数据的查询,而查询结果会得到

ResulSet对象,ResulSet表示执行查询数据库后返回的数据的集合,ResulSet对象具有可以指向当前数据行的指针。通过该对象的next()方法,使得指针指向下一行,然后将数据以列号或者字段名取出。如果当next()方法返回null,则表示下一行中没有数据存在。使用示例代码如下:

ResultSet resultSel =

statementexecuteQuery( "select from staff" );

8 关闭数据库连接:使用完数据库或者不需要访问数据库时,通过Connection的close() 方法及时关闭数据连接。

use 库名

go -----打开库

create table 学生信息

(学号 int not null,

姓名 char(10) not null,

班级 nvarchar(20)

成绩 int )

go -----这是建表

(1)insert into 学生信息(学号,姓名,班级,成绩)

values('122153032','小静',‘计应123’,'99') ----这是插入记录以此类推插入五条

(2)select

from 学生信息

where 成绩>85 -----显示成绩大于85分的学生信息

(3) select

from 学生信息

order by 成绩desc ---将表中的所有记录,按照成绩从小到大顺序排列

能帮你的只有这些,望采纳!

      获取数据库的连接 

      @return conn 

     /  

    public static  Connection getConnection() throws Exception{  

      String url = "jdbc:mysql://101035188:3306/sgjwx";  

      String user = "opermain";  

      String psw = "opermain";  

      Connection conn = null;

      PreparedStatement pstm = null;

      ResultSet rs = null;

     ClassforName("commysqljdbcDriver");  

        if(null == conn) {  

            try {  

                conn = DriverManagergetConnection(url, user, psw);  

            } catch (SQLException e) {  

                Systemoutprintln("获取失败");

                throw new RuntimeException(e);  

            } finally{

             closeResources(conn,pstm,rs);

            } 

        }  

        return conn;  

    }  

    / 

      释放资源 

      @param conn 

      @param pstmt 

      @param rs 

     /  

    public  static void closeResources(Connection conn,PreparedStatement pstmt,ResultSet rs) {  

        if(null != rs) {  

            try {  

                rsclose();  

            } catch (SQLException e) {  

                eprintStackTrace();  

                throw new RuntimeException(e);  

            } finally {  

                if(null != pstmt) {  

                    try {  

                        pstmtclose();  

                    } catch (SQLException e) {  

                        eprintStackTrace();  

                        throw new RuntimeException(e);  

                    } finally {  

                        if(null != conn) {  

                            try {  

                                connclose();  

                            } catch (SQLException e) {  

                                eprintStackTrace();  

                                throw new RuntimeException(e);  

                            }  

                        }  

                    }  

                }  

            }  

        }  

    } 

    

    

    //       //tuserrole执行插入

//         try {

//          String sql = "insert into sys_userrole(roleid,userid) values (,)";

//             conn = getConnection();  

//             connsetAutoCommit(false);  

//             PreparedStatement pstmt = (PreparedStatement) connprepareStatement(sql,StatementRETURN_GENERATED_KEYS);//传入参数:StatementRETURN_GENERATED_KEYS

//             pstmtsetInt(1, 5);

//             pstmtsetInt(2, sid);

//             pstmtexecuteUpdate();

//             ResultSet rs = pstmtgetGeneratedKeys(); //获取结果   

//             int a = -1;

//          if (rsnext()) {

//          a = rsgetInt(1);//取得ID

//          }

//          Systemoutprintln(a);

//             Systemoutprintln("t_userrole执行成功");

//             conncommit(); 

//         } catch (Exception e) {  

//          eprintStackTrace();

//          Systemoutprintln("执行失败");

//         }

百度一下JDBC,创建数据表需要好多的,你首先要连接数据库,单纯的创建的话比较简单,你用普通的sql语句就好,把它存在一个变量中带入数据就可以

sql="INSERT INTO rtNews(author,title,create_time,content,isdelete) VALUES ('"+username+"','"+newsTitle+"','"+ddte+"','"+newsContent+"',1)

这是个插入语句,创建的,我就不写了暂时没有现成的那个括号中的值”+ 变量+“就是变量

MySQL[1]

是一个关系型数据库管理系统,由瑞典 MySQL AB 公司开发,目前属于 Oracle 旗下公司。MySQL 最流行的关系型数据库管理系统,在 WEB 应用方面 MySQL 是最好的 RDBMS (Relational Database Management System,关系数据库管理系统) 应用软件之一。MySQL 是一种关联数据库管理系统,

关联数据库将数据保存在不同的表中,而不是将所有数据放在一个大仓库内,这样就增加了速度并提高了灵活性。MySQL 所使用的 SQL

语言是用于访问数据库的最常用标准化语言。MySQL

软件采用了双授权政策,它分为社区版和商业版,由于其体积小、速度快、总体拥有成本低,尤其是开放源码这一特点,一般中小型网站的开发都选择 MySQL 作为网站数据库。由于其社区版的性能卓越,搭配 PHP 和 Apache 可组成良好的开发环境。

import javasql;

public class DataBasePractice {

public static void main(String[] args) {

//声明Connection对象

Connection con;

//驱动程序名

String driver = "commysqljdbcDriver";

//URL指向要访问的数据库名mydata

String url = "jdbc:mysql://localhost:3306/mydata";

//MySQL配置时的用户名

String user = "root";

//MySQL配置时的密码

String password = "root";

//遍历查询结果集

try {

//加载驱动程序

ClassforName(driver);

//1getConnection()方法,连接MySQL数据库!!

con = DriverManagergetConnection(url,user,password);

if(!conisClosed())

Systemoutprintln("Succeeded connecting to the Database!");

//2创建statement类对象,用来执行SQL语句!!

Statement statement = concreateStatement();

//要执行的SQL语句

String sql = "select from student";

//3ResultSet类,用来存放获取的结果集!!

ResultSet rs = statementexecuteQuery(sql);

Systemoutprintln("-----------------");

Systemoutprintln("执行结果如下所示:");

Systemoutprintln("-----------------");

Systemoutprintln(" 学号" + "\t" + " 姓名");

Systemoutprintln("-----------------");

String name = null;

String id = null;

while(rsnext()){

//获取stuname这列数据

name = rsgetString("stuname");

//获取stuid这列数据

id = rsgetString("stuid");

//首先使用ISO-8859-1字符集将name解码为字节序列并将结果存储新的字节数组中。

//然后使用GB2312字符集解码指定的字节数组。

name = new String(namegetBytes("ISO-8859-1"),"gb2312");

//输出结果

Systemoutprintln(id + "\t" + name);

}

rsclose();

conclose();

} catch(ClassNotFoundException e) {

//数据库驱动类异常处理

Systemoutprintln("Sorry,can`t find the Driver!");

eprintStackTrace();

} catch(SQLException e) {

//数据库连接失败异常处理

eprintStackTrace();

}catch (Exception e) {

// TODO: handle exception

eprintStackTrace();

}finally{

Systemoutprintln("数据库数据成功获取!!");

}

}

}

在上面while代码段后面添加以下代码段:

String name = null;

String id = null;

while(rsnext()){

//获取stuname这列数据

name = rsgetString("stuname");

//获取stuid这列数据

id = rsgetString("stuid");

//首先使用ISO-8859-1字符集将name解码为字节序列并将结果存储新的字节数组中。

//然后使用GB2312字符集解码指定的字节数组。

name = new String(namegetBytes("ISO-8859-1"),"gb2312");

//输出结果

Systemoutprintln(id + "\t" + name);

}

PreparedStatement psql;

ResultSet res;

//预处理添加数据,其中有两个参数--“?”

psql = conprepareStatement("insert into student values(,)");

psqlsetInt(1, 8); //设置参数1,创建id为5的数据

psqlsetString(2, "xiaogang"); //设置参数2,name 为小明

psqlexecuteUpdate(); //执行更新

//预处理更新(修改)数据

psql = conprepareStatement("update student set stuname = where stuid = ");

psqlsetString(1,"xiaowang"); //设置参数1,将name改为王五

psqlsetInt(2,10); //设置参数2,将id为2的数据做修改

psqlexecuteUpdate();

//预处理删除数据

psql = conprepareStatement("delete from student where stuid = ");

psqlsetInt(1, 5);

psqlexecuteUpdate();

//查询修改数据后student表中的数据

psql = conprepareStatement("selectfrom student");

res = psqlexecuteQuery(); //执行预处理sql语句

Systemoutprintln("执行增加、修改、删除后的数据");

while(resnext()){

name = resgetString("stuname");

id = resgetString("stuid");

name = new String(namegetBytes("ISO-8859-1"),"gb2312");

Systemoutprintln(id + "\t" + name);

}

resclose();

psqlclose();

使用java连接MySQL数据库与其他的数据库连接核心是一样的,如果说区别,那就是所需的驱动不一样。

工具/原料

MySQL、JDK

方法/步骤

1、首先需要安装好JDK(配置环境变量),如图所示:

2、其次要安装好MySQL数据库,可以使用可视化Navicar For MySQL,如图所示:

3、最后通过代码进行连接。

(1)确定连接路径URL:

String url="jdbc:mysql://localhost(可以是本机IP地址):3306(端口号)/mysqltest(数据库名称)?"+"user=用户账号&password=用户密码&useUnicode=字符编码";

(2)加载驱动:

ClassforName("commysqljdbcDriver");

(3)连接,获取Connection对象

Connection conn=DriverManagergetConnection(url)

(4)可以通过conn对象检验连接与否。

以上就是关于java怎么返回mysql协议全部的内容,包括:java怎么返回mysql协议、java习题:使用mysql数据库创建学生信息表、如何在Java程序中访问mysql数据库中的数据并进行简单的 *** 作等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!

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

原文地址:https://54852.com/sjk/9593459.html

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

发表评论

登录后才能评论

评论列表(0条)

    保存