[Home] [Help]
The following lines contain the word 'select', 'insert', 'update' or 'delete':
SELECT
ID,
OBJECT_VERSION_NUMBER,
IBC_ID,
VERSION,
LOSS_RATE,
START_DATE,
NVL(END_DATE,OKL_API.G_MISS_DATE) END_DATE,
NVL(COMMENTS,OKL_API.G_MISS_CHAR) COMMENTS,
NVL(PROGRAM_ID,OKL_API.G_MISS_NUM) PROGRAM_ID,
NVL(REQUEST_ID,OKL_API.G_MISS_NUM) REQUEST_ID,
NVL(PROGRAM_APPLICATION_ID,OKL_API.G_MISS_NUM) PROGRAM_APPLICATION_ID,
NVL(PROGRAM_UPDATE_DATE,OKL_API.G_MISS_DATE) PROGRAM_UPDATE_DATE,
CREATED_BY,
LAST_UPDATED_BY,
CREATION_DATE,
LAST_UPDATE_DATE,
NVL(LAST_UPDATE_LOGIN,OKL_API.G_MISS_NUM) LAST_UPDATE_LOGIN
FROM OKL_BUCKETS_V
WHERE OKL_BUCKETS_V.id = p_id;
l_bktv_rec.PROGRAM_UPDATE_DATE,
l_bktv_rec.CREATED_BY,
l_bktv_rec.LAST_UPDATED_BY,
l_bktv_rec.CREATION_DATE,
l_bktv_rec.LAST_UPDATE_DATE,
l_bktv_rec.LAST_UPDATE_LOGIN;
PROCEDURE check_updates (
p_upd_bktv_rec IN bktv_rec_type,
p_db_bktv_rec IN bktv_rec_type,
p_bktv_rec IN bktv_rec_type,
x_return_status OUT NOCOPY VARCHAR2,
x_msg_data OUT NOCOPY VARCHAR2
) IS
l_bktv_rec bktv_rec_type;
END check_updates;
-- call verify changes to update the database
IF l_bktv_rec.end_date > l_db_bktv_rec.end_date THEN
check_updates(p_upd_bktv_rec => l_upd_bktv_rec,
p_db_bktv_rec => l_db_bktv_rec,
p_bktv_rec => l_bktv_rec,
x_return_status => l_return_status,
x_msg_data => x_msg_data);
/* public api to insert streamtype */
OKL_BUCKETS_PUB.INSERT_BUCKETS(p_api_version => l_api_version,
p_init_msg_list => p_init_msg_list,
x_return_status => l_return_status,
x_msg_count => x_msg_count,
x_msg_data => x_msg_data,
p_bktv_rec => l_bktv_rec,
x_bktv_rec => x_bktv_rec);
PROCEDURE update_buckets(p_api_version IN NUMBER,
p_init_msg_list IN VARCHAR2 DEFAULT OKC_API.G_FALSE,
x_return_status OUT NOCOPY VARCHAR2,
x_msg_count OUT NOCOPY NUMBER,
x_msg_data OUT NOCOPY VARCHAR2,
p_bktv_rec IN bktv_rec_type,
x_bktv_rec OUT NOCOPY bktv_rec_type
) IS
l_api_version CONSTANT NUMBER := 1;
l_api_name CONSTANT VARCHAR2(30) := 'update_buckets';
-- this is to take care of records created and updated on the same start date.
IF l_oldversion_enddate < l_bktv_rec.start_date THEN
l_bktv_rec.end_date := l_bktv_rec.start_date;
-- call verify changes to update the database
IF l_oldversion_enddate > l_db_bktv_rec.end_date THEN
check_updates(p_upd_bktv_rec => l_upd_bktv_rec,
p_db_bktv_rec => l_db_bktv_rec,
p_bktv_rec => l_bktv_rec,
x_return_status => l_return_status,
x_msg_data => x_msg_data);
-- public api to update buckets
OKL_BUCKETS_PUB.UPDATE_BUCKETS(p_api_version => l_api_version,
p_init_msg_list => p_init_msg_list,
x_return_status => l_return_status,
x_msg_count => x_msg_count,
x_msg_data => x_msg_data,
p_bktv_rec => l_bktv_rec,
x_bktv_rec => x_bktv_rec);
-- call verify changes to update the database
IF l_bktv_rec.end_date > l_db_bktv_rec.end_date THEN
check_updates(p_upd_bktv_rec => l_upd_bktv_rec,
p_db_bktv_rec => l_db_bktv_rec,
p_bktv_rec => l_bktv_rec,
x_return_status => l_return_status,
x_msg_data => x_msg_data);
-- public api to insert buckets
OKL_BUCKETS_PUB.INSERT_BUCKETS(p_api_version => l_api_version,
p_init_msg_list => p_init_msg_list,
x_return_status => l_return_status,
x_msg_count => x_msg_count,
x_msg_data => x_msg_data,
p_bktv_rec => l_bktv_rec,
x_bktv_rec => x_bktv_rec);
-- public api to insert buckets
OKL_BUCKETS_PUB.INSERT_BUCKETS(p_api_version => l_api_version,
p_init_msg_list => p_init_msg_list,
x_return_status => l_return_status,
x_msg_count => x_msg_count,
x_msg_data => x_msg_data,
p_bktv_rec => l_bktv_rec,
x_bktv_rec => x_bktv_rec);
END update_buckets;
OKL_BUCKETS_PUB.INSERT_BUCKETS(p_api_version => l_api_version,
p_init_msg_list => p_init_msg_list,
x_return_status => x_return_Status,
x_msg_count => x_msg_count,
x_msg_data => x_msg_data,
p_bktv_tbl => p_bktv_tbl,
x_bktv_tbl => x_bktv_tbl);
PROCEDURE update_buckets(
p_api_version IN NUMBER,
p_init_msg_list IN VARCHAR2 DEFAULT OKC_API.G_FALSE,
x_return_status OUT NOCOPY VARCHAR2,
x_msg_count OUT NOCOPY NUMBER,
x_msg_data OUT NOCOPY VARCHAR2,
p_bktv_tbl IN bktv_tbl_type,
x_bktv_tbl OUT NOCOPY bktv_tbl_type)
IS
l_api_version NUMBER := 1.0;
OKL_BUCKETS_PUB.UPDATE_BUCKETS(p_api_version => l_api_version,
p_init_msg_list => p_init_msg_list,
x_return_status => x_return_Status,
x_msg_count => x_msg_count,
x_msg_data => x_msg_data,
p_bktv_tbl => p_bktv_tbl,
x_bktv_tbl => x_bktv_tbl);
END update_buckets;
PROCEDURE delete_buckets(
p_api_version IN NUMBER,
p_init_msg_list IN VARCHAR2 DEFAULT OKC_API.G_FALSE,
x_return_status OUT NOCOPY VARCHAR2,
x_msg_count OUT NOCOPY NUMBER,
x_msg_data OUT NOCOPY VARCHAR2,
p_bktv_rec IN bktv_rec_type)
IS
l_api_version NUMBER := 1.0;
OKL_BUCKETS_PUB.DELETE_BUCKETS(p_api_version => l_api_version,
p_init_msg_list => p_init_msg_list,
x_return_status => x_return_Status,
x_msg_count => x_msg_count,
x_msg_data => x_msg_data,
p_bktv_rec => p_bktv_rec);
END delete_buckets;
PROCEDURE delete_buckets(
p_api_version IN NUMBER,
p_init_msg_list IN VARCHAR2 DEFAULT OKC_API.G_FALSE,
x_return_status OUT NOCOPY VARCHAR2,
x_msg_count OUT NOCOPY NUMBER,
x_msg_data OUT NOCOPY VARCHAR2,
p_bktv_tbl IN bktv_tbl_type)
IS
l_api_version NUMBER := 1.0;
OKL_BUCKETS_PUB.DELETE_BUCKETS(p_api_version => l_api_version,
p_init_msg_list => p_init_msg_list,
x_return_status => x_return_Status,
x_msg_count => x_msg_count,
x_msg_data => x_msg_data,
p_bktv_tbl => p_bktv_tbl);
END delete_buckets;