大数据实验——mysql服务的启动

黑马程序的mysql服务启动密码是hadoop

直接在主控制台上输出mysql -u root -p

然后输入密码进入mysql服务

 剩下的就是在finallshell里面进行一些建表增删改查操作，

还有一个问题就是通过java代码进行对表数据的增删改查

我才用的方法是在Navicat里面建一个node1主机的链接然后就可以直接像操作mysql那样操作了

在Navicat里面新建连接的方式：navicat链接虚拟机上hive环境下的MySQL - 王庆园 - 博客园 (cnblogs.com)

package util;
import java.sql.*;
public class mysqltest {
    
    
     
        /**
         * @param args
         */
        //JDBC DRIVER and DB
        static final String  DRIVER="com.mysql.jdbc.Driver";
        static final String DB="jdbc:mysql://node1/mysql?serverTimezone=GMT%2B8&useSSL=false&severTimezone=UTC&seUnicode=true&characterEncoding=utf-8";
         
        //Database auth
        static final String USER="root";
        static final String PASSWD="hadoop";
        
        public static void main(String[] args) {
            // TODO Auto-generated method stub
            Connection conn=null;
            Statement stmt=null;
            ResultSet rs=null;
            try {
                //加载驱动程序
                Class.forName(DRIVER);
                System.out.println("Connecting to a selected database...");
                //打开一个连接
                conn=DriverManager.getConnection(DB, USER, PASSWD);
                
                stmt=conn.createStatement();
                String sql="insert into student values('scofield',45,89,100)";
                stmt.executeUpdate(sql);
                System.out.println("Inserting records into the table successfully!");
                //执行一个查询
//                stmt=conn.createStatement();
                sql="select name,English from student where name='scofield' ";
                
                rs=stmt.executeQuery(sql);
                System.out.println("name"+"\t\t"+"English");
                while(rs.next())
                {
                    System.out.print(rs.getString(1)+"\t\t");
                    System.out.println(rs.getInt(2));
                }
            } catch (ClassNotFoundException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }finally
            {
                if(stmt!=null)
                    try {
                        stmt.close();
                    } catch (SQLException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                if(conn!=null)
                    try {
                        conn.close();
                    } catch (SQLException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
            }
        }

}

运行结果