AI 助理
备案控制台
开发者社区 数据库 文章 正文

C++ 操作 Oracle

2017-02-22 947
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： #include <string>#include <occi.h>#include <iostream>using namespace std;using namespace oracle::occi;struct Student_struct{ int no; int age; string name;};std 


#include <string>
#include <occi.h>
#include <iostream>

using namespace std;
using namespace oracle::occi;

struct Student_struct
{
	int no;	
	int age;
	string name;
};


std::string getSQL(void)
{
	std::string str_sql = "SELECT *	FROM emp WHERE mgr=(:1)";
	return str_sql;
}

/* 连接 Oracle 操作步骤 */
void connectOracle()
{
	const string userName = "scott";
	const string password = "tiger";
	const string connString = "localhost:1521/orcl";	
	try
	{
		Environment *env =  Environment::createEnvironment(Environment::DEFAULT);
		Connection *con = env->createConnection(userName, password,  connString);
		cout << "Success to connect!" << endl;
		Statement *stmt = con->createStatement();
		
		//动态 SQL
		stmt->setSQL("SELECT *	FROM emp WHERE mgr=(:1) AND sal=(:2)");
		stmt->setInt(1, 7902);
		stmt->setInt(2, 800);
		ResultSet *rs = stmt->executeQuery();
		while (rs->next())
		{
			 int no = rs->getInt(1);
			 string name = rs->getString(2);
			 cout << "no is:" << no << endl;
			 cout << "name :" << name << endl;
			 cout << "MGR : "<<rs->getInt(4)<<endl;
			 cout << "SAL :"<<rs->getInt(6)<<endl;
		}
		con->terminateStatement(stmt);
		env->terminateConnection(con);
		Environment::terminateEnvironment(env);
	}
	catch (SQLException &ex)
	{
		cout << ex.what() << endl;
	}
	system("pause");
}

/* 增加 数据  */
void insertData(Connection *p_conn)
{

    Statement *p_stmt = NULL;
    int m_no;

    string m_name;
    //string m_name;
    int m_age;
    int Flag = 0;
    //执行sql，返回结果并显示
    cout << "PLEASE INPUT THE no! " << endl;
    for(;;)
    {
        fflush(stdin);
        if((!scanf_s("%d", &m_no)) || (m_no) < 0)
        {
            cout << "The no that you just input is invalid,please input it again !" << endl;
            continue;
        }
        else
            break;
    }
    string Verify_strsql( "select * from student where no =(:1)" );
    p_stmt = p_conn->createStatement( Verify_strsql );
    p_stmt->setInt(1, m_no);
    ResultSet *rset = p_stmt-> executeQuery();
    /*while( rset->next() )
    {
    	Flag = rset->getInt(1);
    }*/
    rset->next();
    Flag = rset->getInt(1);

    if((m_no != 0) && (Flag != m_no)) /*判断是否为0或已经存在*/
    {
        try
        {
            cout << "PLEASE INPUT THE name! " << endl;
            cin >> m_name;
            cout << "PLEASE INPUT THE age! " << endl;
            for(;;)
            {
                fflush(stdin);
                if((!scanf_s("%d", &m_age)) || (m_age) < 0)
                {
                    cout << "The age that you just input is invalid,please input it again !!" << endl;
                    continue;
                }
                else
                    break;
            }
            string strsql = "insert into student (no,name,age) values (:1,:2,:3)";
            p_stmt = p_conn->createStatement( strsql );
            //p_stmt->setSQL(strsql);
            p_stmt->setInt(1, m_no);
            p_stmt->setString(2, m_name);
            p_stmt->setInt(3, m_age);
            cout << "The Statement that you input is " << strsql << endl;
            p_stmt-> executeUpdate();
            p_conn->commit();
            cout << "Successfully inserted a new record ! " << endl;
        }
        catch(SQLException *e)
        {
            cout << "exception: " << e->what() << endl;
        }
        p_conn->terminateStatement(p_stmt);
    }
    else
    {
        cout << "The user_no is invalid or has been exist!,please input it again!" << endl;
    }
}

/* 删除 数据  */
void deleteData(Connection *p_conn)
{
    int m_no;
    int Flag = 0;
    Statement *p_stmt = NULL;
    //执行sql，返回结果并显示
    //delete_data:
    cout << "Please input the number that you want to delete  :" << endl;
    for(;;)
    {
        fflush(stdin);
        if(!scanf_s("%d", &m_no))
        {
            cout << "输入字符出错！请重新输入!" << endl;
            continue;
        }
        else
            break;
    }
    string Verify_strsql( "select * from student where no =(:1)" );
    p_stmt = p_conn->createStatement( Verify_strsql );
    p_stmt->setInt(1, m_no);
    ResultSet *rset = p_stmt-> executeQuery();
    /*while( rset->next() )
    {
    	Flag = rset->getInt(1);

    }*/
    rset->next();
    Flag = rset->getInt(1);
    if(Flag)
    {
        string strsql( "delete from student where no = (:1)");
        p_stmt = p_conn->createStatement( strsql );
        p_stmt->setInt(1, m_no);
        try
        {
            p_stmt-> executeUpdate();
            p_conn->commit();
            cout << "Successfully deleted an old record !" << endl;
        }
        catch(SQLException *e)
        {
            cout << "exception: " << e->what() << endl;
        }

    }
    else
    {
        cout << "The number that you just input didn't exist! please input a new number!" << endl;
        cout << "_____________________________________________________________________" << endl;
        //goto delete_data;
    }

    p_conn->terminateStatement(p_stmt);

}

/* 修改 数据 */
void setData(Connection *p_conn)
{

    Statement *p_stmt = NULL;
    try
    {
        int m_no;
        int Flag = 0;
        string m_name;
        int m_age;
        cout << "Please input the number that you want to updata :" << endl;
        //cin>>m_no;
        for(;;)
        {
            fflush(stdin);
            if(!scanf_s("%d", &m_no))
            {
                cout << "输入字符出错！请重新输入!" << endl;
                continue;
            }
            else
                break;
        }
        string Verify_strsql( "select * from student where no =(:1)" );
        p_stmt = p_conn->createStatement( Verify_strsql );
        p_stmt->setInt(1, m_no);
        ResultSet *rset = p_stmt-> executeQuery();
        /*while( rset->next() )
        {
        	Flag = rset->getInt(1);

        }*/
        rset->next();
        Flag = rset->getInt(1);
        if(Flag)
        {
            cout << "PLEASE INPUT THE NEW name! " << endl;
            cin >> m_name;
            cout << "PLEASE INPUT THE NEW age! " << endl;
            //cin>>m_age;
            for(;;)
            {
                fflush(stdin);
                if((!scanf_s("%d", &m_age)) || (m_age) < 0)
                {
                    cout << "The age that you just input is invalid,please input it again !!" << endl;
                    continue;
                }
                else
                    break;
            }
            string strsql = "update student set name=(:1),age=(:2) where no=(:3)";
            p_stmt = p_conn->createStatement( strsql );
            //p_stmt -> setSQL(strsql);
            int number = m_no;
            string name = m_name;
            int age = m_age;
            p_stmt->setInt(2, age);
            p_stmt->setString(1, name);
            p_stmt->setInt(3, number);
            p_stmt-> executeUpdate();
            //cout <<"The Statement that you input is "<<strsql<< endl;
            cout << p_stmt->getSQL() << endl;
            p_conn->commit();
            cout << "           SUCCESSFULLY UPDATA A NEW RECORD !" << endl;
        }
        else
        {
            cout << "The number that you just input didn't exist!please input a new number!" << endl;
            cout << "_____________________________________________________________________" << endl;

        }
    }
    catch(SQLException *e)
    {
        cout << "exception: " << e->what() << endl;
    }

    p_conn->terminateStatement(p_stmt);

}

/* 查找 数据 */
void displayData(Connection *p_conn)
{
	Statement *p_stmt = NULL;
	int row = 1;
	string strsql( "select * from student order by no" );
	p_stmt = p_conn->createStatement( strsql );
	ResultSet *rset = p_stmt-> executeQuery();          //查询语句
	try
	{
		cout << setiosflags(ios::left) << setw(5) << "行号" << setiosflags(ios::left) << setw(5) << "     编号" << setiosflags(ios::left) << setw(8) << "        姓名" << setiosflags(ios::left) << setw(8) << "              年龄" << endl;
		while( rset->next() )
		{
			int no = rset->getInt(1);
			int age = rset->getInt(3);
			string name = rset->getString(2);
			cout << "row." << setiosflags(ios::left) << setw(5) << row << " no=" << setiosflags(ios::left) << setw(5) << no << "    name=" << setiosflags(ios::left) << setw(8) << name << "     age=" << setiosflags(ios::left) << setw(10) << age << endl;
			row++;
		}
	}
	catch (SQLException *e)
	{
		cout << "exception: " << e->what() << endl;
	}
	p_stmt->closeResultSet(rset);

	p_conn->terminateStatement(p_stmt);

}


void findData(Connection *p_conn)
{
    Statement *p_stmt = NULL;
    int no;
    int Flag = 0;
    cout << "Please input the number that you want to search :" << endl;
    //cin>> no;
    for(;;)
    {
        fflush(stdin);
        if(!scanf_s("%d", &no))
        {
            cout << "输入字符出错！请重新输入!" << endl;
            continue;
        }
        else
            break;
    }
    string Verify_strsql( "select * from student where no =(:1)" );
    p_stmt = p_conn->createStatement( Verify_strsql );
    p_stmt->setInt(1, no);
    ResultSet *rset = p_stmt-> executeQuery();
    /*while( rset->next() )
    {
    	Flag = rset->getInt(1);

    }*/
    rset->next();
    Flag = rset->getInt(1);
    if(Flag)
    {
        string strsql( "select * from student where no =(:1)" );
        p_stmt = p_conn->createStatement( strsql );
        p_stmt->setInt(1, no);
        ResultSet *rset = p_stmt-> executeQuery();          //查询语句
        try
        {
            while( rset->next() )
            {
                int no = rset->getInt(1);
                int age = rset->getInt(3);
                string name = rset->getString(2);
                cout << "no==" << no << "  name==" << name << "  age==" << age << endl;
            }
        }
        catch (SQLException *e)
        {
            cout << "exception: " << e->what() << endl;
        }
    }
    else
    {
        cout << "The data that you just input didn't exist! please input a new number!" << endl;
        cout << "___________________________________________________________________" << endl;
    }
    p_stmt->closeResultSet(rset);

    p_conn->terminateStatement(p_stmt);

}

void Export_data(Connection *p_conn)
{
    unsigned int i = 0;
    Statement *p_stmt = NULL;
    Student_struct    m_struct_student;
    vector<Student_struct>   stu_strc;
    stu_strc.reserve(100);
    string strsql( "select * from student order by no" );
    p_stmt = p_conn->createStatement( strsql );
    ResultSet *rset = p_stmt-> executeQuery();          //查询语句
    try
    {
        while( rset->next() )
        {
            m_struct_student.no = rset->getInt(1);
            m_struct_student.age = rset->getInt(3);
            m_struct_student.name = rset->getString(2);
            stu_strc.push_back(m_struct_student);
        }
        /*vector<Student_struct>::iterator iter;
        iter = stu_strc.begin();
        while(iter != stu_strc.end())
        {
        	cout<<*(iter++)<<endl;
        }*/

        ofstream Vector_to_file("d:\\Database_file.txt");
        if(!Vector_to_file)
        {
            cout << "error" << endl;
            return;
        }
        else
        {
            for(i = 0; i < stu_strc.size(); i++)
            {
                Vector_to_file << setiosflags(ios::left) << setw(8) << stu_strc[i].no << setiosflags(ios::left) << setw(8) << stu_strc[i].name << "  " << setiosflags(ios::left) << setw(8) << stu_strc[i].age << endl;
            }
            Vector_to_file.close();

            cout << "您已成功将以下数据写入d:\\Database_file.txt文件中 !" << endl;
            cout << endl;
            cout << setiosflags(ios::left) << setw(8) << "编号" << "  " << setiosflags(ios::left) << setw(8) << "姓名" << "  " << setiosflags(ios::left) << setw(8) << "年龄" << endl;
            for(i = 0; i < stu_strc.size(); i++)
            {
                cout << setiosflags(ios::left) << setw(8) << stu_strc[i].no << "  " << setiosflags(ios::left) << setw(8) << stu_strc[i].name << "  " << setiosflags(ios::left) << setw(8) << stu_strc[i].age << endl;
            }
        }

        //return EXIT_SUCCESS;
    }
    catch (SQLException *e)
    {
        cout << "exception: " << e->what() << endl;
    }
    p_stmt->closeResultSet(rset);

    p_conn->terminateStatement(p_stmt);

}


void Vector_save(Connection *p_conn)
{
    Statement *p_stmt = NULL;
    Student_struct    m_struct_student;//结构体变量
    vector<Student_struct>   stu_strc;//声明一个向量
    stu_strc.reserve(100);
    string strsql( "select * from student order by no" );
    p_stmt = p_conn->createStatement( strsql );
    ResultSet *rset = p_stmt-> executeQuery();          //查询语句
    try
    {
        while( rset->next() )
        {
            m_struct_student.no = rset->getInt(1);
            m_struct_student.age = rset->getInt(3);
            m_struct_student.name = rset->getString(2);
            stu_strc.push_back(m_struct_student);
        }
        /*vector<Student_struct>::iterator iter;
        iter = stu_strc.begin();
        while(iter != stu_strc.end())
        {
        	cout<<*(iter++)<<endl;
        }*/

        cout << "您已成功将以下数据装入vector容器中 !" << endl;
        cout << endl;
        cout << setiosflags(ios::left) << setw(5) << "编号" << "  " << setiosflags(ios::left) << setw(5) << "姓名" << "  " << setiosflags(ios::left) << setw(5) << "年龄" << endl;
        for(unsigned int i = 0; i < stu_strc.size(); i++)
        {
            cout << setiosflags(ios::left) << setw(5) << stu_strc[i].no << "  " << setiosflags(ios::left) << setw(5) << stu_strc[i].name << "  " << setiosflags(ios::left) << setw(5) << stu_strc[i].age << endl;
        }
    }
    catch (SQLException *e)
    {
        cout << "exception: " << e->what() << endl;
    }
    p_stmt->closeResultSet(rset);

    p_conn->terminateStatement(p_stmt);

}



int main()
{
	connectOracle();
	return 0;

}


文章标签：
iOS开发
关系型数据库
C++
SQL
Oracle
容器
关键词：
Oracle数据库一键上云操作
C++操作
c++ oracle数据库一键上云
C++ oracle
shadowcat
目录
相关文章
嘟嘟嘟嘟嘟嘟
|
7月前
|
Oracle 关系型数据库 Java
实时计算 Flink版操作报错之读取Oracle数据库时遇到找不到驱动，是什么原因
在使用实时计算Flink版过程中，可能会遇到各种错误，了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题，查看Flink的日志是关键，它们通常会提供更详细的错误信息和堆栈跟踪，有助于定位问题。此外，Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
嘟嘟嘟嘟嘟嘟
283 1
实时计算 Flink版操作报错之读取Oracle数据库时遇到找不到驱动，是什么原因
西柚与蓝莓
|
5月前
|
C++ 容器
C++中向量的操作vector
C++中向量的操作vector
西柚与蓝莓
53 6
嘟嘟嘟嘟嘟嘟
|
7月前
|
Oracle 关系型数据库 MySQL
实时计算 Flink版操作报错之遇到报错 Oracle 19C，如何解决
在使用实时计算Flink版过程中，可能会遇到各种错误，了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题，查看Flink的日志是关键，它们通常会提供更详细的错误信息和堆栈跟踪，有助于定位问题。此外，Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
嘟嘟嘟嘟嘟嘟
166 1
以山向海
|
5月前
|
Oracle 关系型数据库 数据库
关系型数据库Oracle执行备份或恢复操作
【7月更文挑战第25天】
以山向海
64 3
花开富贵111
|
5月前
|
分布式计算 Oracle 大数据
MaxCompute产品使用合集之没有数据源，只是将批量状态和时间写入Oracle表里，该如何操作
MaxCompute作为一款全面的大数据处理平台，广泛应用于各类大数据分析、数据挖掘、BI及机器学习场景。掌握其核心功能、熟练操作流程、遵循最佳实践，可以帮助用户高效、安全地管理和利用海量数据。以下是一个关于MaxCompute产品使用的合集，涵盖了其核心功能、应用场景、操作流程以及最佳实践等内容。
花开富贵111
72 8
拂去尘世尘
|
6月前
|
算法 前端开发 Linux
【常用技巧】C++ STL容器操作：6种常用场景算法
STL在Linux C++中使用的非常普遍，掌握并合适的使用各种容器至关重要！
拂去尘世尘
98 10
长梦
|
6月前
|
C++ iOS开发 开发者
C++一分钟之-文件输入输出(I/O)操作
【6月更文挑战第24天】C++的文件I/O涉及`ifstream`, `ofstream`和`fstream`类，用于读写操作。常见问题包括未检查文件打开状态、忘记关闭文件、写入模式覆盖文件及字符编码不匹配。避免这些问题的方法有：检查`is_open()`、显式关闭文件或使用RAII、选择适当打开模式（如追加`ios::app`）以及处理字符编码。示例代码展示了读文件和追加写入文件的实践。理解这些要点能帮助编写更健壮的代码。
长梦
76 2
好奇的菜鸟
|
6月前
|
C++
C++职工管理系统（类继承、文件、指针操作、中文乱码解决）
C++职工管理系统（类继承、文件、指针操作、中文乱码解决）
好奇的菜鸟
70 0
C++职工管理系统（类继承、文件、指针操作、中文乱码解决）
冲冲冲c
|
6月前
|
SQL DataWorks Oracle
DataWorks产品使用合集之datax解析oracle增量log日志该如何操作
DataWorks作为一站式的数据开发与治理平台，提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案，帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述，涵盖数据处理的各个环节。
冲冲冲c
66 0
游客6z2krsj5iqmue
|
7月前
|
C++
在C和C++中，指针的算术操作
在C和C++中，指针的算术操作
游客6z2krsj5iqmue
58 1