ERROR [Microsoft][ODBC SQL Server Driver][SQL Server]Violation of PRIMARY KEY constraint 'PK_RIG'. Cannot insert duplicate key in object 'dbo.DOROW'. The duplicate key value is [...]
****************** ASSERT FAILED: Assertion failed in C:\Users\GIRU1\ToolsBox\upp-2020.1\uppsrc\ODBC\ODBC.cpp, line 215
tlevel >= 0

bool InsertDoument(ValueMap * vm){

	Sql query(my_mssql_db);
	query.ClearError();

	query.Begin();

	try{
		query * Insert(My_mssql_table)(*vm);
	} catch(SqlExc) {
		ErrorOK(query.GetLastError());
	}

	if(query.WasError()){
		query.Rollback();
		return false;
	}

	query.Commit();
    return true;
}

sqlite3.Open(db)
#ifdef _DEBUG
    sqlite3.SetTrace();		//logging queries
#endif

// initialize transaction
BEGIN TRAN;
// transaction
INSERT INTO sales
VALUES ('7896', 'JR3435', 'Oct 28 1997', 25, 'Net 60', 'BU7832');

BEGIN TRY
    BEGIN TRANSACTION 
        exec( @sqlHeader)
    COMMIT
END TRY
BEGIN CATCH
    IF @@TRANCOUNT > 0
        ROLLBACK
END CATCH

(mymssql_db is a private memeber of the class and its type is MSSQLSession).

bool OpenMSSqlDB(){

	String username = "sa";
	String pwd = "mypassword";
	String dbname = "MYDBNAME";
	String server = "servername\\instancename";
	String cs = "Driver={SQL Server};Server=" + server +
					";UID=" + username + ";PWD=" + pwd + ";Database=" + dbname + ";";
	if(!mymssql_db.Connect(cs))
	{
		string err="Unable to connect to MSSql database due to the following error: " + mymssql_db.GetLastError().ToStd();
		this->err_messages->push_back(err);
		return false;
	}

	mymssql_db.ThrowOnError();
	mymssql_db.LogErrors();
	mymssql_db.SetTrace();

	return true;
}

#include <Core/Core.h>
#include <plugin/sqlite3/Sqlite3.h>

using namespace Upp;

CONSOLE_APP_MAIN
{
	Cout() << "Start" << EOL;
	
	Sqlite3Session myDB;	// <<<<<<<<<<<<<< ADOPT TO YOUR MS_Sql_Server.....
	if(!myDB.Open(ConfigFile("DATA.db"))) {
		LOG("Can't create or open database file\n");
		return;
	}
#ifdef _DEBUG
	myDB.SetTrace();
#endif

	SQL = myDB;	
	// ======================= initial data
	String s = "[{\"A\":\"valA1\", \"B\":\"valB1\"}, {\"A\":\"valA2\", \"B\":\"valB2\"}]";
	ValueMap js=ParseJSON(s);   // frankly speaking ValueArray should be perhaps, but it works for me...
	int jsz=js.GetCount();
	
	// ======================= create tbl
	SQL.Execute("drop table IF EXISTS tbl;");
	SQL.Execute("create table IF NOT EXISTS tbl (A STRING , B STRING, PRIMARY KEY (A));");
	
	// ======================= insert into tbl
	Sql query(myDB);		// (my_db)
	query.SetStatement("INSERT INTO tbl ( A, B) VALUES ( ?, ?) ");
	// initialize transaction
	query.Begin();
        // loop to insert rows
	for(size_t i = 0; i < jsz; i++) {			
	   	query.SetParam(0,~js[i]["A"]);
	   	query.SetParam(1,~js[i]["B"]);	   	
		query.Execute();			
	}
	// error behavior
	if(query.WasError()){
		Cout() << query.GetLastError();
		query.Rollback();
		return;		// false;
	}
	//Save data & unlock db
	query.Commit();
	Cout() << "Done" << EOL;
	
	// ======================= select to console_view	
	if (query.Execute("SELECT * FROM tbl"))
	{
		Cout() << "Call succeeded" << EOL;
		
		for (int i = 0; i < query.GetColumnCount(); ++i) {
			Cout() << Format("%d: %s", i, query.GetColumnInfo(i).name) << EOL;
		}
		
		while (query.Fetch()) {
			Cout() << query[0] << " ; " << query[1] << EOL;
		}
	}
	else
	{
		Cout() << "Call failed" << EOL;
		Cout() << SQL.GetLastError() << EOL;
	}
}

#include "app.h"

#include <Sql/sch_schema.h>
#include <Sql/sch_source.h>

using namespace Upp;

CONSOLE_APP_MAIN
{
	MSSQLSession mssql;
	if(!mssql.Connect("Driver={SQL Server Native Client 11.0};Server=localhost;Database=master;Trusted_Connection=Yes;")) {
		Cout() << "Connect failed: " << mssql.GetLastError() << '\n';
		return;
	}
	
	SQL = mssql;

	SqlSchema sch(MSSQL);
	StdStatementExecutor se(SQL.GetSession());
	All_Tables(sch);
	ODBCPerformScript(sch.Upgrade(), se);
	ODBCPerformScript(sch.Attributes(), se);

#ifdef _DEBUG
	mssql.SetTrace();
	mssql.LogErrors();
	mssql.ThrowOnError();
#endif

	
	SQL.Begin();
	try {
		for(int i = 0; i < 10; i++)
			SQL * Insert(TEST)(ID, i)(TEXT, String('A' + i, 1));
	}
	catch(SqlExc e)
	{
		DDUMP(e);
	}
	
	if(SQL.WasError()) {
		DLOG("There was ERROR!");
		SQL.Rollback();
	}
	else
		SQL.Commit();
	
	S_TEST tst;
	Sql sql;
	sql * Select(tst).From(TEST);
	while(sql.Fetch(tst))
		Cout() << tst.ID << ", " << tst.TEXT << '\n';
}

	if(my_mssql_db.IsOpen()){
		my_mssql_db.Commit();
		my_mssql_db.Close();
	}

bool InsertDocument(ValueMap * header, vector<vm*> * rows){

	Sql query_header(my_mssql_db);
	query_header.ClearError();

	Sql query_body(my_mssql_db);
	query_body.ClearError();

	query_header.Begin();
	query_body.Begin();

  	try{
  		query_heder * Insert(My_mssql_header_table)(*header);
  	} catch(SqlExc) {
  		ErrorOK(query_header.GetLastError());
  	}

	for(vector<vm*>::iterator it = rows->begin(); it != rows->end(); ++it) {
    	try{
    		query_body * Insert(My_mssql_body_table)(*it);
    	} catch(SqlExc) {
    		ErrorOK(query_body.GetLastError());
    	}
    }

	if(query_header.WasError() || query_body.WasError(){
		query_body.Rollback();
		query_header.Rollback();
		return false;
	}

	query_header.Commit();
	query_body.Commit();
    return true;
}

bool InsertDocument(ValueMap * header, vector<vm*> * rows){

	Sql query_header(my_mssql_db);
	query_header.ClearError();

	Sql query_body(my_mssql_db);
	query_body.ClearError();

	query_header.Begin();
	query_body.Begin();